JDBC 快速入门

当前版本:v3.0, 更新时间:2020-09-16

在项目中导入jar包 “pinusdb_jdbc_3.x.x.jar” 即可。

public class Test {
public static void printResultSet(ResultSet rs) throws SQLException {
ResultSetMetaData rsMeta = rs.getMetaData();
int colCnt = rsMeta.getColumnCount();
for(int i = 1; i <= colCnt; i++) {
System.out.print("--");
System.out.print(rsMeta.getColumnName(i));
    System.out.print(",");
    System.out.print(rsMeta.getColumnTypeName(i));
    System.out.print("--|");
}
System.out.println();
while(rs.next()) {
    for(int i = 1; i <= colCnt; i++) {
    System.out.print(rs.getObject(i).toString());
    System.out.print("  |  ");
    }
    System.out.println();
}
}
public static void Query(String connStr, String querySql) {
try {
Connection conn = DriverManager.getConnection(connStr);
    Statement statement = conn.createStatement();
    ResultSet rs = statement.executeQuery(querySql);
    printResultSet(rs);
    rs.close();
    conn.close();
} catch (SQLException ex) {
    System.out.println("Exception:");
    System.out.println(ex.getMessage());
}
}
public static void main(String[] args) throws ClassNotFoundException {
Class.forName("cn.pinusdb.jdbc.PDBDriver");
String connStr = "jdbc:pinusdb://127.0.0.1:8105?user=sa&password=pinusdb";
Query(connStr, "select * from sys_table");
}
}