（一） 前言
本文说明如何连接Oracle、MySQL、sqlserver，以及执行sql、获取查询结果等。
（二） DB-API
DB-API阐明一系列所需对象和数据库访问机制的标准。
Python操作数据库的模块如果遵循DB-API的标准（应该都会遵循这个标准），函数、方法的名称及功能应该是差不多的（下面几张表格列出了部分内容），就是传的参数可能有点区别。
connect函数
connect函数通过connection对象访问数据库。该函数创建并返回一个connection对象。
|
参数 |
说明 |
|
host |
数据库实例的访问地址（例如：IP实例名） |
|
user |
用户名 |
|
password |
密码 |
|
database |
数据库名 |
connection对象
|
方法 |
说明 |
|
close() |
关闭数据库连接 |
|
commit() |
提交事务 |
|
rollback() |
取消事务 |
|
cursor() |
使用该连接创建并返回一个游标对象（或类游标对象） |
cursor对象
（感觉比较重要的就下面这3个）
|
方法 |
说明 |
|
execute() |
执行SQL |
|
fetchall() |
获取查询结果（执行select 语句后） |
|
callproc() |
调用存储过程 |
异常
|
异常 |
说明 |
|
DataError |
处理数据时出现问题 |
|
OperationalError |
数据库操作执行期间出现问题 |
|
IntegrityError |
数据库关系完整性错误 |
|
ProgrammingError |
SQL执行失败 |
（三） 模块安装
Oracle：pip install cx_Oracle
Mysql: pip install pymysql
sql server：https://www.lfd.uci.edu/~gohlke/pythonlibs/ 下载pymssql，然后 pip install xxx.whl。（pip install pymssql 安装不了再用这种方式,上面2个如果安装不了也可以用这种方式去安装）
（四） Oracle示例
从下面3个示例可以看出，代码其实基本相同，只是导入的模块不一样（其他数据库应该也是差不多的）。
import cx_Oracle # 连接数据库,参数：用户名/密码@服务器ip:端口号/实例名 conn = cx_Oracle.connect('py/password@192.168.4.196:1521/orcl') # 创建游标对象 cur = conn.cursor() #执行SQL cur.execute("insert into test_py t values('1005','ZS','张三','123456')") cur.execute("update test_py t set t.user_name='李四' where t.id='123' ") #提交事务 conn.commit() #执行SQL cur.execute("select * from test_py") #获得查询结果 row = cur.fetchall() print(row) #关闭数据库连接 conn.close()
（五） MySql示例
1 import pymysql 2 3 # 连接数据库,host:服务器ip user：用户名 password：密码 database：数据库名 4 conn = pymysql.connect(host='192.168.4.196', user='root', password='password', database='test') 5 # 创建游标对象 6 cur = conn.cursor() 7 #执行SQL 8 cur.execute("insert into test_py(id,user_account) values('100','admin')") 9 cur.execute("update test_py set user_account = 'test6' where id='123'") 10 #提交事务 11 conn.commit() 12 #执行SQL 13 cur.execute("select * from test_py") 14 #获得查询结果 15 row = cur.fetchall() 16 print(row) 17 #关闭数据库连接 18 conn.close()
（六） Sql server 示例
import pymssql # 连接数据库,host:服务器ip\实例名 user：用户名 password：密码 database：数据库名 conn = pymssql.connect(host='192.168.4.196\amsys', user='sa', password='123', database='test') # 创建游标对象 cur = conn.cursor() #执行SQL cur.execute("insert into test_py(id,user_account) values('100861','admin')") cur.execute("update test_py set user_account = 'test6' where id='123'") #提交事务 conn.commit() #执行SQL cur.execute("select * from test_py") #获得查询结果 row = cur.fetchall() print(row) #关闭数据库连接 conn.close()