python基础(九) - 调用数据库 及 增、删、改、查 等操作

1、安装pymysql 及 命令说明

# 安装pymysql

# pip install pymysql

# cmd 管理员运行

2、调用数据库

import pymysql

# pymysql.connect(host,user,passwd,port,db,charset) 链接数据库

# conn.cursor() 操作游标

# cursor.execute(sql,parm) 执行sql语句

# cursor.fetchmany(num) 从结果集中获取指定数目的记录

# cursor.fetchone() 得到结果集一条记录

# cursor.fetchall() 得到结果集所有记录

conn = pymysql.connect(host='localhost',user='root', password='123456',db='test',port=3306,charset='utf8')

cursor=conn.cursor()#创建游标

#在当前链接的数据库里创建表

# createSql="create table if not exists tableTemp(Name varchar(20) not null,ID int)"

# cursor.execute(createSql)

3、不带参访问数据库 增删改查操作

##新建记录

createSql="INSERT INTO tableTemp VALUES('张三',1),('李四',2)"

cursor.execute(createSql)

# 修改记录

createSql="UPDATE tableTemp SET NAME='了了了' WHERE ID=1"

cursor.execute(createSql)

# 删除记录

createSql="DELETE FROM tableTemp WHERE ID=2"

cursor.execute(createSql)

# 查询数据

createSql="SELECT * FROM tableTemp"

result=cursor.execute(createSql)

cursor.fetchone();

4、带参访问数据库 增删改查操作

tempSql="insert into tableTemp values(%s,%s)"

parm=('李同学','18')

cursor.execute(tempSql,parm)

tempSql="insert into tableTemp values(%(name)s,%(id)s)"

value = {'name':'zhangsan','id':'12'};

cursor.execute(tempSql,value)

conn.commit()#向数据库提交操作

cursor.close()#关键游标

conn.close()#关闭链接

5、通用的访问数据的代码

# region 数据库相关操作 【增、删、改、查】

def executeSql(str):

conn = pymssql.pymssql.connect(host="127.0.0.1",database="DW",user="sa",password="123456")

cur = conn.cursor()

cur.execute(str)

conn.commit()

cur.close()

conn.close()

def selectSql(strdat):

conn = pymssql.connect(host="127.0.0.1",database="DW",user="sa",password="123456")

cur = conn.cursor()

cur.execute(strdat)

result = cur.fetchall()

# print(str(result[1]).encode('latin-1').decode('gbk'))

df = pd.DataFrame(list(result))

conn.commit()

cur.close()

conn.close()

return df

def executeMany(insertSql,data):

conn = pymssql.connect(host="127.0.0.1",database="DW",user="sa",password="123456")

cur = conn.cursor()

cur.executemany(insertSql,tuple(data))

conn.commit()

cur.close()

conn.close()

# endregion 数据库相关操作

如果喜欢，请点个赞数据库查询操作，您的支持，是对我最大的鼓励~

（编辑：应用网_常德站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!