连接并登陆数据库

# 导入cx_oracle
import cx_oracle as oracle

 

# 连接并登陆数据库 入参：     user      password  ip地址与实例
      db = oracle.connect(username, password, ip:port/example)

# 使用tns串连接
oracle_tns = cx_Oracle.makedsn('XXX.XXX.XXX', 1521,'oracleName')
db = oracle.connect(username,pass,oracle_tns)

# 简洁连接
db = oracle.connect(username/password@ip:port/example)

 

创建游标对象

 # 创建游标对象
 cu = db.cursor()

 

执行sql语句

sql_statement = f"select * from tablename where 条件"    # sql语句

cu.execute(sql_statement )  # 执行sql

one_result = cu.fetchone()  # 得到单行数据
all_result = cu.fetchall()  # 得到全部数据

 

查询结果显示

# 查询结果仅显示3行

numline = 3
sql_statement = f" select * from tablename where rownum <={numline} "


# 将查询数据与表列名组成元组

for i in result:
    list_list = list(i)

    des = cursor.description  # 获取表详情

    t = ",".join([item[0] for item in des]) 
    table_head = t.split(',')  # # 查询表列名 用,分割

    dict_result = dict(zip(table_head, list_list))  # 打包为元组的列表 在转换为字典
    list_result.append(dict_result)  # 将字典添加到list_result中

 

关闭数据库

• 增、删、改操作都需要当前连接进行提交事务后再，关闭游标及数据库连接

# 提交事务
conn.commit（）

#关闭游标
cu.close()

#关闭连接
conn.close()

 

 

拓展

cx_oracle 安装失败，解决办法：https://www.cnblogs.com/phoenixy/p/15205039.html

 

预处理语句 [待补充]

cu.prepare(sql)

 

插入语句可以使用多条插入

executemany(None, recordList)

 

如果python连接cx_oracle 时出现乱码

import os
os.environ['NLS_LANG'] = 'SIMPLIFIED CHINESE_CHINA.UTF8'