淘宝店购买网站,库存管理系统,模拟搜索点击软件,网页游戏大全免费工作需要操作MySQL数据库#xff0c;使用pymysql库#xff0c;有些操作上不习惯的地方做了些修改。比如查询的时候结果不能按字段名读取数据等。以下是代码。
首先是引入库、引入random和string主要是为了生成id。
import pymysql
import random
import string
创建数据库…
工作需要操作MySQL数据库使用pymysql库有些操作上不习惯的地方做了些修改。比如查询的时候结果不能按字段名读取数据等。以下是代码。
首先是引入库、引入random和string主要是为了生成id。
import pymysql
import random
import string
创建数据库链接对象
def mysqlconnect():# 连接数据库host 192.168.1.1port 3306user rootpassword rootdatabase ceshi_tableconn pymysql.connect(hosthost, portport, useruser, passwordpassword, databasedatabase)cursor conn.cursor()return cursor,conn
一、查询方法
def selectdata(sql_query):cursor,conn mysqlconnect()# 执行SQL查询语句cursor.execute(sql_query)# 获取查询结果results cursor.fetchall()# 查询column_names [desc[0] for desc in cursor.description]data []for row in results:name_value {}for column_name in column_names:name_value[column_name] row[column_names.index(column_name)]data.append(name_value)# 关闭游标和连接cursor.close()conn.close()if len(data) 1:return data[0]else:return data
调用
sql_query SELECT * FROM data_table
results selectdata(sql_query)
print(results)
二、添加数据方法
def insertdata(insertsql,values):cursor,conn mysqlconnect()try:if type(values) list:cursor.executemany(insertsql, values)if type(values) tuple:cursor.execute(insertsql, values)conn.commit()except Exception as e:print(f数据插入失败{e})conn.rollback()# 关闭游标和连接cursor.close()conn.close()
调用
insertsql insert into data_table (id,warning_type,customer,license,tel) values (%s,%s,%s,%s,%s)
values [(123133, 123123,城区据,第一市场队),
(123125, 123123,城区据,第一市场队),
(123178, 123123,城区据,第一市场队)]
# values (123127, 123123,城区据,第一市场队)
insertdata(insertsql,values)
三、更新数据方法
def updatedata(update_sql,values):cursor,conn mysqlconnect()try:cursor.execute(update_sql, values)conn.commit()except Exception as e:print(f数据更新失败{e})conn.rollback()# 关闭游标和连接cursor.close()conn.close()
调用
update_sql UPDATE data_table SET area_name%s,squadron_code%s WHERE id%s
values (new_value1, condition_value,123123)
updatedata(update_sql,values)
四、删除数据方法
def deledata(delete_sql,delevalue):cursor, conn mysqlconnect()try:cursor.execute(delete_sql, delevalue)conn.commit()except Exception as e:print(f数据删除失败{e})conn.rollback()# 关闭游标和连接cursor.close()conn.close()
调用
delete_sql DELETE FROM data_table WHERE id%s
values (123123)
deledata(delete_sql,values)
五、最后还有个生成随机字符串id的方法
def generate_random_string(length):characters string.ascii_letters string.digits # 包含所有大小写字母和数字random_string .join(random.choice(characters) for _ in range(length))return random_string
ok完毕
