安装
pip3 install pymysql
连接数据库的??
import pymysql
def connect_mysql():
'''连接数据库方法'''
#连接数据库
conn = pymysql.connect(host="tmysql.***.com",port=3306,user="kevin",passwd="******",database="HT_IMDB")
#使用cursor()方法创建一个游标对象
cursor = conn.cursor()
#使用execute()方法执行SQL语句
cursor.execute("SELECT * FROM HT_VIRTUAL_GIFT")
#使用fetall()获取全部数据
data = cursor.fetchall()
cursor.close()
conn.close()
#关闭游标和数据库的连接
return data
for i in connect_mysql():
print(i)
connect 方法的参数
|
参数
|
功能
|
|
user
|
访问数据库的用户
|
|
password
|
访问数据库的密码
|
|
host
|
Mysql 数据库服务所在的主机
|
|
port
|
Mysql 数据库服务的端口号，默认值为 3306
|
|
db
|
数据库名
|
|
charset
|
字符编码
|
connect 对象
- 使用 connect() 方法与数据库连接成功后，connect() 方法返回一个 connect() 对象
- 与数据库进行通信时, 向 connect 对象发送 SQL 查询命令, 并 connect 对象接收 SQL 查询结果
cursor 对象
- cursor 对象用于执行 SQL 命令和得到 SQL 查询结果
常用方法
|
方法
|
功能
|
|
close()
|
关闭游标对象
|
|
execute()
|
执行一个数据库查询或命令
|
|
fetchone()
|
返回结果集的下一行
|
|
fetchall()
|
返回结果集中所有行
|
#插入三条数据
>>>curs.execute("insert into myDatabase values(0,'lily',23,'California')")
>>>curs.execute("insert into myDatabase values(1,'paul',25,'texas')")
>>>curs.execute("insert into myDatabase values(2,'allen',26,'norway')")
>>>conn.commit()
#查询
>>> curs.execute('select * from myDatabase')
>>> curs.fetchall()
[(0, u'lily', 23, u'California'), (1, u'paul', 25, u'texas'), (2, u'allen', 26, u'norway')]
#修改
>>> curs.execute("update myDatabase set name='lucy' where id=0")
>>> conn.commit()
#删除
>>> curs.execute('delete from myDatabase where id =1')
>>> conn.commit()
#优化
try:
# 执行SQL语句
cursor.execute(sql)
# 向数据库提交
db.commit()
except:
# 发生错误时回滚
db.rollback()