public void close() if (dataSource != null && !dataSource.isClosed()) dataSource.close();
CopyManager copyManager = ((PGConnection) conn).getCopyAPI(); String sql = "COPY users (name, email) FROM STDIN"; CopyIn copyIn = copyManager.copyIn(sql); BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(copyIn)); writer.write("Alice\talice@example.com\n"); writer.write("Bob\tbob@example.com\n"); writer.close(); long rows = copyIn.getHandledRowCount(); 7.3 Logical Replication (PG 10+) PGConnection pgConn = conn.unwrap(PGConnection.class); PGReplicationStream stream = pgConn.getReplicationAPI() .replicationStream() .logical() .withSlotName("test_slot") .withSlotOption("proto_version", "1") .withSlotOption("publication_names", "mypub") .start(); while (true) ByteBuffer msg = stream.readPending(); if (msg != null) // process changes postgres jdbc driver
// Store array Integer[] intArray = 1, 2, 3; Array array = conn.createArrayOf("integer", intArray); pstmt.setArray(1, array); // Read array Array resultArray = rs.getArray("int_array"); Integer[] values = (Integer[]) resultArray.getArray(); public void close() if (dataSource
postgresql-<version>.jar Maven coordinates: CopyManager copyManager = ((PGConnection) conn).getCopyAPI()
JSON/JSONB:
Class.forName("org.postgresql.Driver"); // not required in modern Java