JDBC Manual

key1=value1
key2=value2
...
keyN=valueN

Ocient> SET AUTOCOMMIT OFF;
Ocient> INSERT INTO public.txn_demo VALUES (1, 'alpha');
Ocient> INSERT INTO public.txn_demo VALUES (2, 'beta');
Ocient> SELECT count(*) AS n_in_txn FROM public.txn_demo;
Ocient> COMMIT;

Ocient> INSERT INTO public.txn_demo VALUES (3, 'gamma');
Ocient> INSERT INTO public.txn_demo VALUES (4, 'delta');
Ocient> SELECT count(*) AS n_in_txn FROM public.txn_demo;
Ocient> ROLLBACK;
Ocient> SELECT count(*) FROM public.txn_demo;

Class.forName("com.ocient.jdbc.JDBCDriver");

CONNECT TO 'jdbc:ocient://db.example.com:6432/salesdb;user=admin@system;password=admin;logLevel=INFO;networkTimeout=15000;enableBulkLoad=true;bulkLoadThreshold=50000';

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;

public class OcientConnectionExample {
    public static void main(String[] args) throws SQLException {
        // Base JDBC URL: host, port, and database
        String url = "jdbc:ocient://db.example.com:6432/salesdb";

        // JDBC connection properties
        Properties props = new Properties();
        props.setProperty("user", "analytics_user");            // Ocient username
        props.setProperty("password", "StrongPassw0rd!");       // Ocient password
        props.setProperty("logLevel", "INFO");                  // Driver logging verbosity
        props.setProperty("networkTimeout", "15000");           // 15s network timeout (ms)
        props.setProperty("enableBulkLoad", "true");            // Use bulk load for large batches
        props.setProperty("bulkLoadThreshold", "50000");        // Min rows for bulk loa
        try (Connection conn = DriverManager.getConnection(url, props)) {
        }
    }
}

java -Dcom.ocient.jdbc.rs.disable-memory-throttle=true \
  -classpath ocient-jdbc4-jar-with-dependencies.jar com.ocient.cli.CLI

public class OcientJDBCExample {
     public static void main(final String args[]) {
          Class.forName("com.ocient.jdbc.JDBCDriver");
          Properties props = new Properties();
          props.setProperty("user", "username");
          props.setProperty("password", "pwd");
          props.setProperty("force", "true");
          String url = "jdbc:ocient://192.168.121.82:4050/db";
          Connection conn = DriverManager.getConnection(url, props);
          PreparedStatement pstmt = conn.prepareStatement(
                              "select l_orderkey from tpch.lineitem where l_linenumber = ?");
          Pstmt.setInt(1, 4);
          ResultSet rs = pstmt.executeQuery();
          while(rs.next()){
               // do something with row
          }
          rs.close();
          pstmt.close();
          conn.close();
          return;
     }
}

import java.sql.*;
import java.util.Properties;

public class TxnApi {
  static void show(Connection c, String label) throws SQLException {
    try (Statement s = c.createStatement();
         ResultSet rs = s.executeQuery("SELECT count(*) AS n FROM public.txn_demo")) {
      rs.next();
      System.out.println(label + " -> row count = " + rs.getInt("n"));
    }
  }
  public static void main(String[] args) throws Exception {
    String url = "jdbc:ocient://db.example.com:4050/salesdb";
    Properties p = new Properties();
    p.setProperty("user", "admin@system");
    p.setProperty("password", "admin");
    p.setProperty("tls", "unverified");
    try (Connection c = DriverManager.getConnection(url, p)) {

      // DDL must run outside a transaction (autocommit on)
      try (Statement s = c.createStatement()) {
        s.execute("DROP TABLE IF EXISTS public.txn_demo");
        s.execute("CREATE TABLE public.txn_demo (id INT, v VARCHAR(64))");
      }

      // Transaction 1: multiple inserts and read-your-writes, then commit
      c.setAutoCommit(false);
      try (Statement s = c.createStatement()) {
        s.executeUpdate("INSERT INTO public.txn_demo VALUES (1, 'alpha')");
        s.executeUpdate("INSERT INTO public.txn_demo VALUES (2, 'beta')");
        show(c, "T1 in-txn (read-your-writes, expect 2)");
      }
      c.commit();
      show(c, "T1 after COMMIT (expect 2)");

      // Transaction 2: inserts, then rollback
      try (Statement s = c.createStatement()) {
        s.executeUpdate("INSERT INTO public.txn_demo VALUES (3, 'gamma')");
        s.executeUpdate("INSERT INTO public.txn_demo VALUES (4, 'delta')");
        show(c, "T2 in-txn (expect 4)");
      }
      c.rollback();
      show(c, "T2 after ROLLBACK (expect 2)");

      c.setAutoCommit(true);
    }
  }
}