import pymysql
#1、连上数据库 账号 、密码、 Ip、端口号、数据库
#2、建立游标
#3、执行SQL
#4、获取结果
#5、关闭游标
#6、连接关闭
coon=pymysql.connect(
host='192.168.XX.XXX',user='XXX',passwd='123456',
port=3306,db='dbNAME',charset='utf8'
# port必须写成int类型
# charset这里utf8必须写
)
cur=coon.cursor()#建立游标
#执行sql
cur.execute('insert into stu (id,name,sex) VALUE (101,"乐乐","女");')
coon.commit()
cur.execute('select * from stu;')
res=cur.fetchall() #获取所有返回的结果
print(res)
cur.close()
coon.close()
# 数据库函数
def my_db(host,user,passwd,db,sql,port=3306,charset='utf8'):
import pymysql
coon=pymysql.connect(
host=host,
user=user,
passwd=passwd,
db=db,
port=port,
charset=charset
)
cur=coon.cursor()
cur.execute(sql)
if sql.strip()[:6].upper()=='SELECT':
res=cur.fetchall()
else:
coon.commit()
res='ok'
cur.close()
coon.close()
return res