Python操作使用MySQL数据库的实例代码
Python操作MySQL
配置
- win_64
- Ubuntu14.04
- Python3.x
pip安装pymysql模块
直接使用pip安装pipinstallpymysql
win64上直接在cmd中执行
连接本地数据库
使用模块pymysql连接数据库
#!/usr/bin/python #coding=utf-8 importpymysql #连接本地数据库 conn=pymysql.connect(host='localhost',port=3306,user='root',passwd='a123',db='samp_db1',charset='utf8') cursor=conn.cursor() cursor.execute('select*frombigstu') forrowincursor.fetchall(): print(row) #查 cursor.execute('selectid,namefrombigstuwhereage>22') forresincursor.fetchall(): print(str(res[0])+","+res[1]) cursor.close() print('--end--')
输出:
(1,'张三','男',24,datetime.date(2017,3,29),'13666665555') (6,'小刚','男',23,datetime.date(2017,3,11),'778899888') (8,'小霞','女',20,datetime.date(2017,3,13),'13712345678') (12,'小智','男',21,datetime.date(2017,3,7),'13787654321') 1,张三 6,小刚 --end--
可以直接执行sql语句。获得的结果是元组。
增
插入数据
插入一条数据,接上面的代码
insertSql="insertintobigstu(name,sex,age,mobile)values('%s','%s',%d,'%s')" xiuji=('秀吉','男',15,'13400001111') cursor.execute(insertSql%xiuji) conn.commit()#别忘了提交
添加列
在mobile后面添加一列cash
addCo="altertablebigstuaddcashintaftermobile" cursor.execute(addCo)
如果要设置默认值
addCo="altertablebigstuaddcashintdefault0aftermobile" cursor.execute(addCo)
删
删除数据
删除name=秀吉的数据
deleteSql="deletefrombigstuwherename='%s'" cursor.execute(deleteSql%'秀吉')
删除列
删除cash列
dropCo="altertablebigstudropcash" cursor.execute(dropCo)
改
修改数据
更新符合条件的数据
updateSql="updatebigstusetsex='%s'wherename='%s'" updateXiuji=('秀吉','秀吉')#秀吉的性别是秀吉 cursor.execute(updateSql%updateXiuji) conn.commit()
事物处理
给某个记录的cash增加
table="bigstu" addCash="update"+table+"setcash=cash+'%d'wherename='%s'" lucky=(1000,"秀吉") try: cursor.execute(addCash%lucky) exceptExceptionase: conn.rollback() print("加钱失败了") else: conn.commit()
直接执行SQL语句,十分方便
代码片段
给数据库添加列
从json中读取需要添加的列名,获取当前2个表中所有的列名
整理得出需要插入的列名,然后将列插入到相应的表中
importpymysql importjson importos importsecureUtils mapping_keys=json.load(open("key_mapping_db.json","r")) db_keys=[]#json中所有的key forkinmapping_keys.values(): db_keys.append(k) conn=pymysql.connect(host='localhost',port=3306,user='root', passwd='*****',db='db_name',charset='utf8') cursor=conn.cursor() table_main="table_main" main_table_keys=[]#主表的列名 cursor.execute("showcolumnsfrom"+table_main) forrowincursor.fetchall(): main_table_keys.append(row[0]) staff_table_keys=[] cursor.execute("showcolumnsfromtable_second") forrowincursor.fetchall(): staff_table_keys.append(row[0]) need_to_insert_keys=[] forkindb_keys: ifknotinstaff_table_keysandknotinmain_table_keysandknotinneed_to_insert_keys: need_to_insert_keys.append(k) print("needtoinsert"+str(len(need_to_insert_keys))) print(need_to_insert_keys) forkninneed_to_insert_keys: print("addkeytodb"+kn) cursor.execute("altertablestaff_tableadd"+kn+"text") conn.close()
将字段字符改变
这里将main_table_keys中的所有字段改为utf8
#changecolumncharactersettoutf8 forcoinmain_table_keys: change_sql="altertable"+table_main+"modify"+co+"textcharactersetutf8" print(change_sql) cursor.execute(change_sql)
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。