连接数据库

此处以Maven项目为例，使用PostgreSQL JDBC驱动连接PolarDB PostgreSQL版集群。

1. 首先，您需要在pom.xml文件中添加PostgreSQL JDBC驱动的依赖，代码示例：

   <dependency>
     <groupId>org.postgresql</groupId>
     <artifactId>postgresql</artifactId>
     <version>42.2.18</version>
   </dependency>

2. 连接集群。请将参数<HOST>、<PORT>、<USER>、<PASSWORD>、<DATABASE>、<YOUR_TABLE_NAME>及<YOUR_TABLE_COLUMN_NAME>进行替换。

   import java.sql.Connection;
   import java.sql.DriverManager;
   import java.sql.ResultSet;
   import java.sql.Statement;
   
   public class PolarDBConnection {
       public static void main(String[] args) {
           // 数据库URL, 用户名, 密码
           String url = "jdbc:postgresql://<HOST>:<PORT>/<DATABASE>";
           String user = "<USER>";
           String password = "<PASSWORD>";
   
           try {
               // 加载JDBC驱动
               Class.forName("org.postgresql.Driver");
               
               // 建立连接
               Connection conn = DriverManager.getConnection(url, user, password);
               
               // 创建Statement对象
               Statement stmt = conn.createStatement();
               
               // 执行SQL查询
               ResultSet rs = stmt.executeQuery("SELECT * FROM <YOUR_TABLE_NAME>");
               
               // 处理结果集
               while (rs.next()) {
                   System.out.println(rs.getString("<YOUR_TABLE_COLUMN_NAME>"));
               }
               
               // 关闭资源
               rs.close();
               stmt.close();
               conn.close();
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   }

此处以Python3为例，使用psycopg2库连接PolarDB PostgreSQL版集群。

1. 首先，您需要安装psycopg2库。如果您还没有安装，可以通过以下命令进行安装：

   pip3 install psycopg2-binary

2. 连接集群。请将参数<HOST>、<PORT>、<USER>、<PASSWORD>、<DATABASE>及<YOUR_TABLE_NAME>进行替换。

   import psycopg2
   
   try:
       # 连接参数
       conn = psycopg2.connect(
           host="<HOST>",  # 数据库主机地址
           database="<DATABASE>",  # 数据库名称
           user="<USER>",  # 用户名
           password="<PASSWORD>",  # 密码
           port="<PORT>"  # 端口
       )
   
       # 创建游标对象
       cursor = conn.cursor()
   
       # 执行查询
       cursor.execute("SELECT * FROM <YOUR_TABLE_NAME>")
   
       # 获取所有结果
       records = cursor.fetchall()
       for record in records:
           print(record)
           
   except Exception as e:
       print("错误:", e)
   finally:
       # 关闭连接
       if 'cursor' in locals():
           cursor.close()
       if 'conn' in locals():
           conn.close()

此处以go1.23.0为例，使用database/sql包和lib/pq驱动来连接PolarDB PostgreSQL版集群。

1. 首先，您需要安装lib/pq驱动。您可以通过以下命令进行安装：

   go get -u github.com/lib/pq

2. 连接集群。请将参数<HOST>、<PORT>、<USER>、<PASSWORD>、<DATABASE>及<YOUR_TABLE_NAME>进行替换。

   package main
   
   import (
       "database/sql"
       "fmt"
       "log"
   
       _ "github.com/lib/pq" // 初始化驱动
   )
   
   func main() {
       // 连接字符串格式
       connStr := "user=<USER> password=<PASSWORD> dbname=<DATABASE> host=<HOST> port=<PORT> sslmode=disable"
   
       // 打开数据库连接
       db, err := sql.Open("postgres", connStr)
       if err != nil {
           log.Fatal(err)
       }
       defer db.Close() // 程序退出前关闭连接
   
       // 测试连接是否成功
       err = db.Ping()
       if err != nil {
           log.Fatal(err)
       }
       fmt.Println("Connected to PostgreSQL!")
   
       // 执行查询示例
       rows, err := db.Query("SELECT * FROM <YOUR_TABLE_NAME>")
       if err != nil {
           log.Fatal(err)
       }
       defer rows.Close()
   }