首页 > 数据库> 文章详细

使用python或Navicat连接OpenGauss数据库

2022-05-01 00:33:47 阅读：280 来源： 互联网

标签：execute cur python COMPANY Navicat ADDRESS OpenGauss 连接 ID

最近在学习华为的数据库，在学习如何用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中，我们也查询到了相关的数据

标签：execute,cur,python,COMPANY,Navicat,ADDRESS,OpenGauss,连接,ID
来源： https://www.cnblogs.com/chrisng/p/16211954.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9