最近在学习华为的数据库，在学习如何用python来连接数据的时候，一直连接失败，然后官方文档也没有具体说明如何用python来连接，然后被这个东西困扰了我好几天。在网上找了很多资料，终于成功用python连接上了OpenGauss数据库。

在OpenGauss的官方文档中，找到了用于连接OpenGauss数据库的库，Psycopg。（官方文档链接）

首先得安装Psycopg2，直接在命令输入以下命令

pip install psycopg2

切换omm用户

su - omm

添加放行ip

我们需要修改pg_hba.conf文件，具体路径每个人可能不一样。

我的路径在/gaussdb/data/ecs-8eb2里面，然后我们修改文件pg_hba.conf

vim /gaussdb/data/ecs-8eb2/pg_hba.conf

根据上图修改文件增加

host all all 0.0.0.0/0 sha256

修改加密方式

接下来修改文件postgresql.conf

vim /gaussdb/data/ecs-8eb2/postgresql.conf

将password_encryption_type取消注释，并修改为零

我们也可看以下注释

Password storage type, 0 is md5 for PG, 1 is sha256 + md5, 2 is sha256 only

0的时候为md5加密，1为sha256+md5混合加密，2为sha256加密

重启openGauss服务

我们下面一次执行以下指令

gs_ctl reload ,datadir is -D "/gaussdb/data/ecs-8eb2"
gs_om -t stop
gs_om -t start

执行完成后，我们创建一个用户。用户名自行修改，注意不能用omm用户远程登录。

CREATE USER jacky PASSWORD 'Bigdata@123';

接下来我们要给用户赋予权限(不赋予权限在操作时可能会报错)

GRANT ALL PRIVILEGES TO jacky;

端口放行

现在我们登录华为云的官网，更换安全组

点击新建安全组

进入页面在右上角点击创建安全组

注意在入方向规则中添加策略

添加完后，回到刚才的页面

添加勾选openGauss选项，按确定。

Navicat连接

进入navicat，右上角连接，选择PostgreSQL

按照以上方法输入即可，注意主机是你用ssh登录的那个ip，即弹性公网

连接成功，然后操作就和mysql一样了。

Python连接

python连接数据库需要用到psycopg2，相关代码如下

import psycopg2
conn = psycopg2.connect(dbname="postgres",
                            user="jacky",
                            password="Bigdata@123",
                            host="xxx.xxx.xxx",
                            port="26000")
cur = conn.cursor()

# 创建表
cur.execute(
'''
CREATE TABLE COMPANY(
    ID INT PRIMARY KEY     NOT NULL,
    NAME           TEXT    NOT NULL,
    AGE            INT     NOT NULL,
    ADDRESS        CHAR(50),
    SALARY         REAL);
''')
# 数据插入
cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (1, 'Paul', 32, 'California', 20000.00 )");

cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (2, 'Allen', 25, 'Texas', 15000.00 )");

cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (3, 'Teddy', 23, 'Norway', 20000.00 )");

cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) \
      VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 )");
conn.commit()

# 数据查询
cur.execute("SELECT id, name, address, salary  from COMPANY")
rows = cur.fetchall()
for row in rows:
   print("ID = ", row[0])
   print("NAME = ", row[1])
   print("ADDRESS = ", row[2])
   print("SALARY = ", row[3])
conn.close()

在navicat中，我们也查询到了相关的数据