通过JDBC执行SQL

JDBC包与驱动类

• JDBC包

  在linux服务器端源代码目录下执行build.sh，获得驱动jar包postgresql.jar，包位置在源代码目录下。从发布包中获取，包名为openGauss-x.x.x-操作系统版本号-64bit-Jdbc.tar.gz。

  驱动包与PostgreSQL保持兼容，其中类名、类结构与PostgreSQL驱动完全一致，曾经运行于PostgreSQL的应用程序可以直接移植到当前系统使用。

• 驱动类

  在创建数据库连接之前，需要加载数据库驱动类“org.postgresql.Driver”。

  说明： 由于openGauss在JDBC的使用上与PG的使用方法保持兼容，所以同时在同一进程内使用两个JDBC驱动的时候，可能会类名冲突。

加载驱动

在创建数据库连接之前，需要先加载数据库驱动程序。

加载驱动有两种方法：

• 在代码中创建连接之前任意位置隐含装载：Class.forName(“org.postgresql.Driver”);

• 在JVM启动时参数传递：java -Djdbc.drivers=org.postgresql.Driver jdbctest

  说明： 上述jdbctest为测试用例程序的名称。

连接数据库

在创建数据库连接之后，才能使用它来执行SQL语句操作数据。

函数原型

JDBC提供了三个方法，用于创建数据库连接。

• DriverManager.getConnection(String url);
• DriverManager.getConnection(String url, Properties info);
• DriverManager.getConnection(String url, String user, String password);

参数

表 1 数据库连接参数

示例

• 示例1：此示例将演示如何基于openGauss提供的JDBC接口连接数据库。

  //以下代码将获取数据库连接操作封装为一个接口，可通过给定用户名和密码来连接数据库。
  public static Connection getConnect(String username, String passwd)
      {
          //驱动类。
          String driver = "org.postgresql.Driver";
          //数据库连接描述符。
          String sourceURL = "jdbc:postgresql://10.10.0.13:8000/postgres";
          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;
      };
  // 以下代码将使用Properties对象作为参数建立连接
  public static Connection getConnectUseProp(String username, String passwd)
      {
          //驱动类。
          String driver = "org.postgresql.Driver";
          //数据库连接描述符。
          String sourceURL = "jdbc:postgresql://10.10.0.13:8000/postgres?";
          Connection conn = null;
          Properties info = new Properties();
          try
          {
              //加载驱动。
              Class.forName(driver);
          }
          catch( Exception e )
          {
              e.printStackTrace();
              return null;
          }
          try
          {
               info.setProperty("user", username);
               info.setProperty("password", passwd);
               //创建连接。
               conn = DriverManager.getConnection(sourceURL, info);
               System.out.println("Connection succeed!");
          }
          catch(Exception e)
          {
              e.printStackTrace();
              return null;
          }
          return conn;
      };

• 示例2：此示例将演示如何基于openGauss提供的JDBC接口开发应用程序。

  ``` //DBtest.java //演示基于JDBC开发的主要步骤，会涉及创建数据库、创建表、插入数据等。

  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 DBTest {

  //创建数据库连接。 public static Connection GetConnection(String username, String passwd) {

  String driver = "org.postgresql.Driver";
  String sourceURL = "jdbc:postgresql://localhost:8000/postgres";
  Connection conn = null;
  try {
    //加载数据库驱动。
    Class.forName(driver).newInstance();
  } 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;

  };

  //执行普通SQL语句，创建customer_t1表。 public static void CreateTable(Connection conn) {

  Statement stmt = null;
  try {
    stmt = conn.createStatement();
    //执行普通SQL语句。
    int rc = stmt
        .executeUpdate("CREATE TABLE customer_t1(c_customer_sk INTEGER, c_customer_name VARCHAR(32));");
    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_t1 VALUES (?,?)");
    for (int i = 0; i < 3; i++) {
      //添加参数。
      pst.setInt(1, i);
      pst.setString(2, "data " + i);
      pst.addBatch();
    }
    //执行批处理。
    pst.executeBatch();
    pst.close();
  } catch (SQLException e) {
    if (pst != null) {
      try {
        pst.close();
      } catch (SQLException e1) {
      e1.printStackTrace();
      }
    }
    e.printStackTrace();
  }

  }

  //执行预编译语句，更新数据。 public static void ExecPreparedSQL(Connection conn) {

  PreparedStatement pstmt = null;
  try {
    pstmt = conn
        .prepareStatement("UPDATE customer_t1 SET c_customer_name = ? WHERE c_customer_sk = 1");
    pstmt.setString(1, "new Data");
    int rowcount = pstmt.executeUpdate();
    pstmt.close();
  } catch (SQLException e) {
    if (pstmt != null) {
      try {
        pstmt.close();
      } catch (SQLException e1) {
        e1.printStackTrace();
      }
    }
    e.printStackTrace();
  }

  }

//执行存储过程。
  public static void ExecCallableSQL(Connection conn) {
    CallableStatement cstmt = null;
    try {
      cstmt=conn.prepareCall("{? = CALL TESTPROC(?,?,?)}");
      cstmt.setInt(2, 50); 
      cstmt.setInt(1, 20);
      cstmt.setInt(3, 90);
      cstmt.registerOutParameter(4, Types.INTEGER);  //注册out类型的参数，类型为整型。
      cstmt.execute();
      int out = cstmt.getInt(4);  //获取out参数
      System.out.println("The CallableStatment TESTPROC returns:"+out);
      cstmt.close();
    } catch (SQLException e) {
      if (cstmt != null) {
        try {
          cstmt.close();
        } catch (SQLException e1) {
          e1.printStackTrace();
        }
      }
      e.printStackTrace();
    }
  }
  /**
   * 主程序，逐步调用各静态方法。
   * @param args
  */
  public static void main(String[] args) {
    //创建数据库连接。
    Connection conn = GetConnection("tester", "Password1234");
    //创建表。
    CreateTable(conn);
    //批插数据。
    BatchInsertData(conn);
    //执行预编译语句，更新数据。
    ExecPreparedSQL(conn);
    //执行存储过程。
    ExecCallableSQL(conn);
    //关闭数据库连接。
    try {
      conn.close();
    } catch (SQLException e) {
      e.printStackTrace();
    }
  }
}
```