JDBC 连接器

getCatalogs()

获取数据库中所有可用的 catalog 名称。无参数。

示例：

Connection conn = DriverManager.getConnection(url);
DatabaseMetaData metaData = conn.getMetaData();
ResultSet rs = metaData.getCatalogs();

getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types)

获取指定 catalog、schema 下表的相关信息。

参数介绍

• catalog：可选参数，字符串，用于指定表所属的 catalog。
• schemaPattern：可选参数，字符串，用于指定表所属的模式。
• tableNamePattern：必填参数，字符串，用于指定要匹配的表名的模式。
• types：可选参数，字符串数组，用于指定要返回哪些类型的表。注意，DolphinDB 只支持返回 TABLE 类型，因此该字段只能填 “null“ 或者 “TABLE“。

使用说明：

目前仅支持如下三种用法：

1. 传入具体的 catalog；schema, tableName 均为“%”。表示获取该 catalog 下的所有表。
2. 传入具体的 catalog, schema；tableName 为“%”。表示获取该 schema 下的所有 tables。
3. catalog, schema 均为 “null“，tableName 为“%”。表示获取所有内存表。

返回值说明：

将返回一个表，如下为列属性介绍：

• TABLE_CAT：表所属的 catalog 名称。dfs 表将返回对应的值；内存表则返回为空。
• TABLE_NAME：表的名称。
• TABLE_SCHEM：表所属的 schema 名称。
• TABLE_TYPE：表的类型，通常是 "TABLE"。
• REMARKS：表的描述或备注信息，通常为 null。

示例：

1 获取指定的 catalog下的所有表相关信息：

// 获取 "catalog1" 下的所有表信息
ResultSet rs = metaData.getTables("catalog1","%","%", null);

2 获取指定的 catalog、schema 下的所有表相关信息：

// 获取 "catalog1.schema_test" 下的所有表相关信息
ResultSet rs = metaData.getTables("catalog1","schema_test","%", null);

3 获取所有内存表相关信息：

ResultSet rs = metaData.getTables(null,null,"%", null);

getColumns(String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern) 

获取指定 catalog、schema、table 中列的相关信息。

参数介绍：

• catalog：可选参数，字符串，用于指定表所属的 catalog。
• schemaPattern：可选参数，字符串，用于指定表所属的模式。
• tableNamePattern：必填参数，字符串，用于指定要匹配的表名的模式。
• columnNamePattern：可选参数，字符串，用于指定要检索的列的名称模式。目前仅支持填为“%”。

使用说明：

目前仅支持以下两种用法：

1. 传入具体的 catalog, schema, table；columnName 为“%”。表示获取该表下的所有列。
2. catalog, schema 为空；传入具体的 table，columnName 为“%”。表示获取内存表下的列信息。

返回值说明：

将返回一个表，如下为列属性介绍：

• COLUMN_NAME：列名。
• TYPE_NAME：数据类型。
• DATA_TYPE：值为 java.sql.Types。
• EXTRA：暂不支持，返回为 null。
• REMARKS：列信息，返回为 null。
• ORDINAL_POSITION：列在表中的原始位置，从 1 开始。
• IS_NULLABLE：使用 ISO 规则确定列可否包含空数据。只有分布式表的分区列返回 'NO'（不能为空），其他列都返回 'YES'（可以为空）。
• SQL_DATA_TYPES: INT，取 java.sql.Types 的类型值。比如 DolphinDB 中的 STRING 类型对应 VARCHAR，即取 12； DATE 取 91；DECIMAL 32，DECIMAL 64，DECIMAL 128 都取 3。参考 JDBCResultSetMetaData.java Types 方法。

示例：

1 获取 dfs 表的列相关信息

// 获取 catalog1.schema_test.dt 表的所有列相关信息
ResultSet rs = metaData.getColumns("catalog1","schema_test","dt", "%");

2 获取内存表的列相关信息

// 获取内存表 "table1"下的所有列相关信息
ResultSet rs = metaData.getColumns(null, null, "table1", "%");

用法一：

getSchemas()

表示获取当前连接设置的 catalog 下的所有 schema 信息（设置操作参考 setCatalog）。无参数。

用法二：

getSchemas(String catalog, String schemaPattern)

获取指定 catalog 下所有的 schema。

用法二参数介绍：

• catalog：字符串，表示 catalog 的名称。
• schemaPattern：字符串，表示 schema 的名称。目前仅支持填为“%”。

用法二使用说明：

只支持指定 catalog，schemaPattern填为“%”。表示获取指定 catalog 下的所有 schema。

两种用法的返回值说明：

• TABLE_SCHEM：表示 schema 名称。
• TABLE_CATALOG：表示 catalog 名称。

示例：

1 获取当前连接所设定的 catalog 下的所有 schema：

ResultSet rs = metaData.getSchemas();

2 获取指定的 catalog 下的所有 schema 相关信息：

// 获取 "catalog1" 下的所有 schema 相关信息：
ResultSet rs = metaData.getSchemas("catalog1", "%");

getCatalog() 

获取当前 JDBCConnection 中设置的 catalog。无参数。

示例：

Connection conn = DriverManager.getConnection(url);
String catalog = conn.getCatalog();

setCatalog(String catalog) 

设置当前 catalog 名称。

参数介绍：

catalog：字符串，表示 catalog 的名称。

示例：

设置当前 JDBCConnection 的 catalog。

// 设置当前 JDBCConnection 的 catalog 为 "catalog1"
Connection conn = DriverManager.getConnection(url);
String catalog = conn.setCatalog("catalog1");

通过 JDBC 接口对内存表的操作主要是通过 prepareStatement 预置 sql 模板，并通过 set 写入参数，最后通过 executeUpdate 函数填充参数并执行语句。

public static void InMemmoryAddTest(String database, String tableName) {
    try {
        Class.forName(JDBC_DRIVER);
        conn = DriverManager.getConnection(DB_URL_WITHLOGIN);

        JDBCStatement stm = (JDBCStatement) conn.createStatement();
        stm.execute("memTable = loadTable('" + database + "',\"" + tableName + "\")");
        // SQL insert 语句
        stmt = conn.prepareStatement("insert into memTable values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
        stmt.setBoolean(1, true);
        stmt.setByte(2, (byte) 98);
        stmt.setShort(3, (short) 112);
        stmt.setInt(4, 21);
        stmt.setLong(5, 22l);
        stmt.setFloat(6, 2.1f);
        stmt.setDouble(7, 2.1);
        stmt.setString(8, "hello");
        stmt.setDate(9, Date.valueOf(LocalDate.of(2013, 06, 13)));
        stmt.setObject(10, new BasicMonth(YearMonth.of(2016, 06)));
        stmt.setObject(11, Time.valueOf("13:30:10"));
        stmt.setObject(12, LocalTime.of(13, 30));
        stmt.setObject(13, LocalTime.of(13, 30, 10));
        stmt.setObject(14, LocalDateTime.of(2012, 06, 13, 13, 30, 10));
        stmt.setObject(15, LocalDateTime.of(2012, 06, 13, 13, 30, 10, 8000000));
        stmt.setObject(16, LocalTime.of(13, 30, 10, 8007006));
        stmt.setObject(17, LocalDateTime.of(2012, 06, 13, 13, 30, 10, 8007006));
        stmt.executeUpdate();

        // 加载数据库中的表格
        ResultSet rs = stmt.executeQuery("select * from memTable");
        printData(rs);
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        try {
            if (stmt != null)
                stmt.close();
        } catch (SQLException se2) {
        }
        try {
            if (conn != null)
                conn.close();
        } catch (SQLException se) {
            se.printStackTrace();
        }
    }
}

需要删除内存表中数据，需在以下脚本的 "?" 处填相应的的删除条件。

public static void InMemoryDeleteTest(String database, String tableName){
    try {
        Class.forName(JDBC_DRIVER);
        conn = DriverManager.getConnection(DB_URL_WITHLOGIN);
        JDBCStatement stm = (JDBCStatement)conn.createStatement();
        stm.execute("memTable = loadTable('" + database + "',\"" + tableName + "\")");
        // SQL delete 语句
        stmt = conn.prepareStatement("delete from memTable where char = ?");
        stmt.setByte(1, (byte)'A');
        stmt.executeUpdate();
        // 读取表格检查是否删除
        ResultSet rs = stmt.executeQuery("select * from memTable");
        System.out.println("==========InMemoryDeleteTest======================");
        printData(rs);
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        try {
            if (stmt != null)
                stmt.close();
        } catch (SQLException se2) {
        }
        try {
            if (conn != null)
                conn.close();
        } catch (SQLException se) {
            se.printStackTrace();
        }
    }
}

public static void InMemoryUpdateTest(String database, String tableName){
    try {
        Class.forName(JDBC_DRIVER);
        conn = DriverManager.getConnection(DB_URL_WITHLOGIN);
        JDBCStatement stm = (JDBCStatement)conn.createStatement();
        stm.execute("memTable = loadTable('" + database + "',\"" + tableName + "\")");
        // SQL update 语句
        stmt = conn.prepareStatement("update memTable set bool = 0b where char = 97c");
        stmt.executeUpdate();
        // 读取表格检查是否更新
        ResultSet rs = stmt.executeQuery("select * from memTable where char=97c");
        printData(rs);
    } catch (Exception e) {
        e.printStackTrace();
    } finally
    {
        try {
            if (stmt != null)
                stmt.close();
        } catch (SQLException se2) {
        }
        try {
            if (conn != null)
                conn.close();
        } catch (SQLException se) {
            se.printStackTrace();
        }
    }
}

使用 Java API 执行创建分区表的语句，以创建示例所需的分区数据库。示例中使用了 VALUE 方式进行数据分区。需要了解其他分区方式，请点击 DolphinDB 数据库分区教程。

public static boolean CreateValueTable(String database, String tableName, String host, String port) {
    boolean success = false;
    DBConnection db = null;
    StringBuilder sb = new StringBuilder();
    sb.append("login(\"admin\",\"123456\")\n");
    sb.append("n=3000\n");
    sb.append("month=take(2000.01M..2019.05M, n)\n");
    sb.append("x=take(1..1000, n)\n");
    sb.append("t=table(month, x)\n");
    sb.append("if(existsDatabase(\"" + database + "\"))\n" +
              "dropDatabase(\"" + database + "\")\n");
    sb.append("db=database(\"" + database + "\", VALUE, 2000.01M..2019.05M)\n");
    sb.append("pt = db.createPartitionedTable(t, `" + tableName + ", `month)\n");
    sb.append("pt.append!(t)\n");
    db = new DBConnection();
    try {
        db.connect(host, Integer.parseInt(port));
        db.run(sb.toString());
        success = true;
    } catch (NumberFormatException | IOException e) {
        e.printStackTrace();
        success = false;
    } finally {
        if (db != null)
            db.close();
        return success;
    }
}

public static void DFSAddTest(String database, String tableName) {
    try {
        Class.forName(JDBC_DRIVER);

        // dfs 下会预先 load table
        conn = DriverManager.getConnection(DB_URL_WITHLOGIN);
        JDBCStatement stm = (JDBCStatement) conn.createStatement();
        stm.execute("dfsTable = loadTable('" + database + "',\"" + tableName + "\")");
        // SQL insert 语句
        stmt = conn.prepareStatement("insert into dfsTable values(?,?)");
        stmt.setObject(1, new BasicMonth(YearMonth.of(2016, 06)));
        stmt.setInt(2, 3);
        stmt.executeUpdate();
        // 读取表格检查是否新增数据
        ResultSet rs = stmt.executeQuery("select count(*) from loadTable(\"" + database + "\", `"+ tableName +")");
        printData(rs);
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        try {
            if (stmt != null)
                stmt.close();
        } catch (SQLException se2) {
        }
        try {
            if (conn != null)
                conn.close();
        } catch (SQLException se) {
            se.printStackTrace();
        }
    }
}