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

#示例环境介绍

#安装前准备

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

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

2. 可通过执行 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)

   Copied!

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

#JDBC驱动安装

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

   $ mkdir JDBC
   $ cd JDBC

   Copied!

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

3. 配置JDBC驱动环境：

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

      $ vi ~/.bashrc

      Copied!

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

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

      Copied!

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

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

      $ source ~/.bashrc

      Copied!

#编写JAVA文件

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

   $ vi Jdbcexample.java

   Copied!

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");
       }}

   Copied!

   其中：

   • 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;
       }

   Copied!

       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;
       }

   Copied!

3. 执行如下命令进行编译：

   $ javac -d . Jdbcexample.java

   Copied!

4. 执行如下命令执行程序，如输出如下结果，则代表数据库连接成功：

   $ java -Djdbc.drivers=com.yashandb.jdbc.Driver jdbc0.Jdbcexample
   Connection succeed!create table customer succeed!insert table customer succeed!