本章将介绍YashanDB的JDBC驱动的安装及基础的操作演示。

示例环境介绍

软件	版本
JDBC驱动	yashandb-jdbc-1.5.jar
JDK	1.8
JRE	1.8

安装前准备

1. 使用JDBC驱动前须先安装JDK，JDK版本兼容信息如下，请自行安装下述版本的环境：

   • JDK：1.8及以上
   • JRE：1.8及以上

2. 可通过执行java -version命令验证Java环境是否正常：

   $ java -version
   openjdk 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)
   

3. 请联系我们的技术支持获取JDBC驱动软件包，软件包名称示例： yasdb-jdbc-版本号.jar 。

JDBC驱动安装

1. 执行如下命令创建/home/yashan/JDBC目录，请注意区分大小写：

   $ mkdir JDBC
   $ cd JDBC
   

2. 将JDBC软件包上传至该目录中。

3. 配置JDBC驱动环境：

   1. 执行如下命令使用vi编辑器打开文件~/.bashrc：

      $ vi ~/.bashrc
      

   2. 通过i键打开输入模式，并将如下内容输入至文件中，请将yasdb-jdbc-1.5.jar更换成实际软件包名称：

      export CLASSPATH=/home/yashan/JDBC/yasdb-jdbc-1.5.jar:${CLASSPATH} 
      

   3. 通过Esc键退出输入模式，然后输入:wq保存并关闭文件。

   4. 执行如下生效环境变量：

      $ source ~/.bashrc
      

编写JAVA文件

1. 执行如下命令创建Java文件Jdbcexample.java：

   $ vi 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.Jdbcexample
   Connection succeed!
   create table customer succeed!
   insert table customer succeed!