# 通过Python连接RDS for PostgreSQL实例
#### 操作场景
通过Python连接实例的方式有无需下载SSL证书连接和用户下载SSL证书连接两种，其中使用SSL证书连接通过了加密功能，具有更高的安全性。
#### 前提条件
用户需要具备以下技能：
- 熟悉计算机基础知识。
- 了解Python编程语言。
- 了解psycopg2库的基本使用。
 
#### 安装依赖
安装psycopg2模块，它可以连接和查询PostgreSQL数据库。
```
pip install psycopg2
```
#### 参数说明
表1参数说明 
| 参数          | 说明                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                           |
|:---|:---|
| dbname      | 数据库名，即需要连接的数据库名（默认的管理数据库是postgres)。                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          |
| user        | 连接数据库的用户。                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                    |
| password    | 连接数据库时用户的密码。                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                 |
| host        | - 如果通过弹性云服务器连接，则是主机IP，即"概览"页面该实例的"内网地址"。  - 如果通过连接了公网的设备访问，则为该实例已绑定的"弹性公网IP"。                                                                                                                                                                                                                                                          |
| port        | 端口，默认5432，即"概览"页面该实例的"数据库端口"。                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                |
| sslmode     | SSL连接模式。 - disable：表示进行无证书连接，不关心安全性。  - verify-ca： 采用CA认证方式。  - 其它选项参考[社区文档](https://www.postgresql.org/docs/current/libpq-ssl.html)。   |
| sslrootcert | sslrootcert：服务器证书路径。                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                         |
   
#### 连接实例
- [使用SSL证书连接]
  下面的代码使用psycopg2.connect函数，基于SSL证书认证方式，连接到RDS for PostgreSQL数据库实例，并使用SQL INSERT、UPDATE操作数据，使用cursor.execute方法对数据库进行SQL操作：
  ![](https://support.huaweicloud.com/usermanual-rds-pg/public_sys-resources/notice_3.0-zh-cn.png)
  在某些实例版本上，如果创建表报错"permission denied for schema public"，则手动执行**grant create on SCHEMA public to root;**后可以解决。
  ```
  import psycopg2
  db_params ={'database':'postgres','user':'root','password':'****','host':'xxx.xxx.xxx.xxx','port':'5432','sslmode':'verify-ca','sslrootcert':'/path/to/CA/ca.pem',}
  conn=psycopg2.connect(**db_params)
  print("Connection established")
  cursor = conn.cursor()
  # Drop previous table of same name if one exists
  cursor.execute("DROP TABLE IF EXISTS inventory;")
  print("Finished dropping table (if existed)")
  # Create a table
  cursor.execute("grant create on SCHEMA public to root;")
  cursor.execute("CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);")
  print("Finished creating table")
  # Insert some data into the table
  cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);",("banana",150))
  cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);",("orange",154))
  cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);",("apple",100))
  print("Inserted 3 rows of data")
  cursor.execute("SELECT * FROM inventory;")
  result = cursor.fetchall()
  for row in result:
      print(row)
  # Clean up
  conn.commit()
  cursor.close()
  conn.close()
  ```
  输出结果如下：
  ```
  Connection established
  Finished dropping table(if existed)
  Finished creating table
  Inserted 3 rows of data
  (1,'banana',150)
  (2,'orange',154)
  (3,'apple',100)
  ```
- [无证书连接]
  无证书方式连接RDS for PostgreSQL数据库的Python代码，可参考以下示例：
  ```
  import psycopg2
  db_params ={'database':'postgres','user':'root','password':'****','host':'xxx.xxx.xxx.xxx','port':'5432','sslmode':'disable'}
  conn=psycopg2.connect(**db_params)
  print("Connection established")
  cursor = conn.cursor()
  # Drop previous table of same name if one exists
  cursor.execute("DROP TABLE IF EXISTS inventory;")
  print("Finished dropping table (if existed)")
  # Create a table
  cursor.execute("grant create on SCHEMA public to root;")
  cursor.execute("CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);")
  print("Finished creating table")
  # Insert some data into the table
  cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);",("banana",150))
  cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);",("orange",154))
  cursor.execute("INSERT INTO inventory (name, quantity) VALUES (%s, %s);",("apple",100))
  print("Inserted 3 rows of data")
  cursor.execute("SELECT * FROM inventory;")
  result = cursor.fetchall()
  for row in result:
      print(row)
  # Clean up
  conn.commit()
  cursor.close()
  conn.close()
  ```