本章将介绍 YashanDB 的 JDBC 驱动的安装及基础的操作演示。
示例环境介绍
安装前准备
使用 JDBC 驱动前须先安装 JDK，JDK 版本兼容信息如下，请自行安装下述版本的环境：
JDK：1.8 及以上
JRE：1.8 及以上
可通过执行java -version命令验证 Java 环境是否正常：
$ java -versionopenjdk version "1.8.0_372"OpenJDK Runtime Environment (build 1.8.0_372-b07)OpenJDK 64-Bit Server VM (build 25.372-b07, mixed mode)
复制代码
5.请联系我们的技术支持获取 JDBC 驱动软件包，软件包名称示例： yasdb-jdbc-版本号.jar 。
JDBC 驱动安装
执行如下命令创建/home/yashan/JDBC目录，请注意区分大小写：
2.将 JDBC 软件包上传至该目录中。
3.配置 JDBC 驱动环境：
1.执行如下命令使用 vi 编辑器打开文件~/.bashrc：
2.通过i键打开输入模式，并将如下内容输入至文件中，请将yasdb-jdbc-1.5.jar更换成实际软件包名称：
export CLASSPATH=/home/yashan/JDBC/yasdb-jdbc-1.5.jar:${CLASSPATH}
复制代码
3.通过Esc键退出输入模式，然后输入:wq保存并关闭文件。
4.执行如下生效环境变量：
编写 JAVA 文件
执行如下命令创建 Java 文件Jdbcexample.java：
2.通过i键打开输入模式，并将如下内容输入至文件中：
package jdbc0;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.SQLException;import java.sql.Statement;import java.sql.CallableStatement;
public class Jdbcexample { public static Connection getConnection(String username, String passwd) { String driver = "com.yashandb.jdbc.Driver"; String sourceURL = "jdbc:yasdb://host:port/database_name"; Connection conn = null; try { Class.forName(driver); } catch (Exception e) { e.printStackTrace(); return null; }
try { conn = DriverManager.getConnection(sourceURL, username, passwd); System.out.println("Connection succeed!"); } catch (Exception e) { e.printStackTrace(); return null; }
return conn; } public static void createTable(Connection conn) { Statement stmt = null; try { stmt = conn.createStatement(); stmt.execute("DROP TABLE IF EXISTS customer"); stmt.execute("CREATE TABLE customer(id INTEGER, name VARCHAR(32))"); System.out.println("create table customer succeed!"); stmt.close(); } catch (SQLException e) { if (stmt != null) { try { stmt.close(); } catch (SQLException e1) { e1.printStackTrace(); } } e.printStackTrace(); } } public static void batchInsertData(Connection conn) { PreparedStatement pst = null;
try { pst = conn.prepareStatement("INSERT INTO customer VALUES (?,?)"); for (int i = 0; i < 3; i++) { pst.setInt(1, i); pst.setString(2, "sales" + i); pst.addBatch(); } pst.executeBatch(); System.out.println("insert table customer succeed!"); pst.close(); } catch (SQLException e) { if (pst != null) { try { pst.close(); } catch (SQLException e1) { e1.printStackTrace(); } } e.printStackTrace(); } } public static int execJdbcexample(String ctrls) { Connection conn = getConnection(user, password);
createTable(conn);
batchInsertData(conn);
try { conn.close(); } catch (SQLException e) { e.printStackTrace(); return 0; } return 1; }
public static void main(String[] args) { int a = execJdbcexample("1"); }}
复制代码
其中：
String sourceURL = "jdbc:yasdb://host:port/database_name";为数据库连接描述符，请将host:port更换成服务端所在 IP 地址及端口，database_name更换成数据库名称。
Connection conn = getConnection(user, password);用于创建连接，请将user更换成用户名字符串，password更换成该用户的密码字符串。
public static Connection getConnection(String username, String passwd) { String driver = "com.yashandb.jdbc.Driver"; String sourceURL = "jdbc:yasdb://127.0.0.1:1688/yashandb"; Connection conn = null; try { Class.forName(driver); } catch (Exception e) { e.printStackTrace(); return null; }
try { conn = DriverManager.getConnection(sourceURL, username, passwd); System.out.println("Connection succeed!"); } catch (Exception e) { e.printStackTrace(); return null; }
return conn; }
复制代码
public static int execJdbcexample(String ctrls) { Connection conn = getConnection("sys", "password");
createTable(conn);
batchInsertData(conn);
try { conn.close(); } catch (SQLException e) { e.printStackTrace(); return 0; } return 1; }
复制代码
3.执行如下命令进行编译：
$ javac -d . Jdbcexample.java
复制代码
4.执行如下命令执行程序，如输出如下结果，则代表数据库连接成功：
$ java -Djdbc.drivers=com.yashandb.jdbc.Driver jdbc0.JdbcexampleConnection succeed!create table customer succeed!insert table customer succeed!
复制代码
评论