通过JDBC执行SQL

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

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

    • 驱动类

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

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

    加载驱动有两种方法：

    • 在代码中创建连接之前任意位置隐含装载：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接口连接数据库。

      2. public static Connection getConnect(String username, String passwd)
      3.     {
      4.         //驱动类。
      5.         String driver = "org.postgresql.Driver";
      6.         //数据库连接描述符。
      7.         String sourceURL = "jdbc:postgresql://10.10.0.13:8000/postgres";
      8.         Connection conn = null;
      10.         try
      11.         {
      12.             //加载驱动。
      13.             Class.forName(driver);
      14.         }
      15.         catch( Exception e )
      16.         {
      17.             e.printStackTrace();
      18.             return null;
      19.         }
      21.         try
      22.         {
      23.              //创建连接。
      24.             conn = DriverManager.getConnection(sourceURL, username, passwd);
      25.             System.out.println("Connection succeed!");
      26.         }
      27.         catch(Exception e)
      28.         {
      29.             e.printStackTrace();
      30.             return null;
      31.         }
      33.         return conn;
      34.     };
      35. // 以下代码将使用Properties对象作为参数建立连接
      37.     {
      38.         //驱动类。
      39.         String driver = "org.postgresql.Driver";
      40.         //数据库连接描述符。
      41.         String sourceURL = "jdbc:postgresql://10.10.0.13:8000/postgres?";
      42.         Connection conn = null;
      43.         Properties info = new Properties();
      45.         try
      46.             //加载驱动。
      47.             Class.forName(driver);
      48.         }
      49.         catch( Exception e )
      50.         {
      51.             e.printStackTrace();
      52.             return null;
      53.         }
      55.         try
      56.         {
      57.              info.setProperty("user", username);
      58.              info.setProperty("password", passwd);
      59.              //创建连接。
      60.              conn = DriverManager.getConnection(sourceURL, info);
      61.              System.out.println("Connection succeed!");
      62.         }
      63.         catch(Exception e)
      64.         {
      65.             e.printStackTrace();
      66.             return null;
      67.         }
      69.         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) {

      };

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

      1. Statement stmt = null;
      2. try {
      3.   stmt = conn.createStatement();
      5.   //执行普通SQL语句。
      6.   int rc = stmt
      7.       .executeUpdate("CREATE TABLE customer_t1(c_customer_sk INTEGER, c_customer_name VARCHAR(32));");
      9.   stmt.close();
      10. } catch (SQLException e) {
      11.   if (stmt != null) {
      12.     try {
      13.       stmt.close();
      14.     } catch (SQLException e1) {
      15.       e1.printStackTrace();
      16.     }
      17.   }
      18.   e.printStackTrace();
      19. }

      }

      //执行预处理语句，批量插入数据。 public static void BatchInsertData(Connection conn) {

      }

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

      1. PreparedStatement pstmt = null;
      2. try {
      3.   pstmt = conn
      4.       .prepareStatement("UPDATE customer_t1 SET c_customer_name = ? WHERE c_customer_sk = 1");
      5.   pstmt.setString(1, "new Data");
      6.   int rowcount = pstmt.executeUpdate();
      7.   pstmt.close();
      8. } catch (SQLException e) {
      9.   if (pstmt != null) {
      10.     try {
      11.       pstmt.close();
      12.     } catch (SQLException e1) {
      13.       e1.printStackTrace();
      14.     }
      15.   }
      16. }

      }