Python 操作 MySQL数据库
开发环境与配置
- win_x64
- Ubuntu14.04
- Python3.x
pip安装pymysql模块
直接使用pip安装pipinstallpymysql
win64上直接在cmd中执行
连接本地数据库
使用模块pymysql连接数据库
本地数据库相关配置请参阅：http://rustfisher.github.io/2017/02/25/backend/MySQL_install/
#!/usr/bin/python
#coding=utf-8
importpymysql
#连接本地数据库
conn=pymysql.connect(host='localhost',port=3306,user='root',passwd='yourpwd',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语句。获得的结果是元组。
sql相似条件查询
SELECT*FROManindex.subject_basic_tablewhereseason_idhaving'2018';
增
插入数据
插入一条数据，接上面的代码
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)
以上就是Python如何操作MySQL的详细内容，更多关于Python操作MySQL的资料请关注毛票票其它相关文章！