全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

Python操作使用MySQL数据库的实例代码

Python 操作 MySQL

配置

  1. win_64
  2. Ubuntu14.04
  3. Python3.x

pip安装pymysql模块

直接使用pip安装 pip install pymysql

win64上直接在cmd中执行

连接本地数据库

使用模块pymysql连接数据库

#!/usr/bin/python
# coding=utf-8
import pymysql
# 连接本地数据库
conn = pymysql.connect(host='localhost', port=3306, user='root', passwd='a123', db='samp_db1', charset='utf8')
cursor = conn.cursor()
cursor.execute('select * from bigstu')
for row in cursor.fetchall():
  print(row)
# 查
cursor.execute('select id, name from bigstu where age > 22')
for res in cursor.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 = "insert into bigstu (name, sex, age, mobile) values ('%s','%s',%d,'%s') "
xiuji = ('秀吉', '男', 15, '13400001111')
cursor.execute(insertSql % xiuji)
conn.commit() # 别忘了提交

添加列

在mobile后面添加一列cash

addCo = "alter table bigstu add cash int after mobile"
cursor.execute(addCo)

如果要设置默认值

addCo = "alter table bigstu add cash int default 0 after mobile"
cursor.execute(addCo)

删除数据

删除 name=秀吉 的数据

deleteSql = "delete from bigstu where name = '%s'"
cursor.execute(deleteSql % '秀吉')

删除列

删除cash列

dropCo = "alter table bigstu drop cash"
cursor.execute(dropCo)

修改数据

更新符合条件的数据

updateSql = "update bigstu set sex = '%s' where name = '%s'"
updateXiuji = ('秀吉', '秀吉') # 秀吉的性别是秀吉
cursor.execute(updateSql % updateXiuji)
conn.commit()

事物处理

给某个记录的cash增加

table = "bigstu"
addCash = "update " + table + " set cash = cash + '%d' where name = '%s'"
lucky = (1000, "秀吉")
try:
  cursor.execute(addCash % lucky)
except Exception as e:
  conn.rollback()
  print("加钱失败了")
else:
  conn.commit()

直接执行SQL语句,十分方便

代码片段

给数据库添加列

从json中读取需要添加的列名,获取当前2个表中所有的列名

整理得出需要插入的列名,然后将列插入到相应的表中

import pymysql
import json
import os
import secureUtils
mapping_keys = json.load(open("key_mapping_db.json", "r"))
db_keys = [] # json中所有的key
for k in mapping_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("show columns from " + table_main)
for row in cursor.fetchall():
  main_table_keys.append(row[0])
staff_table_keys = []
cursor.execute("show columns from table_second")
for row in cursor.fetchall():
  staff_table_keys.append(row[0])
need_to_insert_keys = []
for k in db_keys:
  if k not in staff_table_keys and k not in main_table_keys and k not in need_to_insert_keys:
    need_to_insert_keys.append(k)
print("need to insert " + str(len(need_to_insert_keys)))
print(need_to_insert_keys)
for kn in need_to_insert_keys:
  print("add key to db " + kn)
  cursor.execute("alter table staff_table add " + kn +" text")
conn.close()

将字段字符改变

这里将main_table_keys中的所有字段改为utf8

# change column character set to utf8
for co in main_table_keys:
  change_sql = "alter table " + table_main + " modify " + co + " text character set utf8"
  print(change_sql)
  cursor.execute(change_sql)

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。


# Python  # 操作  # MySQL  # python对mysql的操作  # python连接mysql  # python递归查询菜单并转换成json实例  # Python发送http请求解析返回json的实例  # python对json的相关操作实例详解  # python查询mysql  # 返回json的实例  # 可以直接  # 别忘了  # 符合条件  # 大家多多  # 默认值  # 连接数据库  # 小霞  # 结果是  # 失败了  # print  # fetchall  # id  # age  # gt  # cursor  # execute  # ol  # br  # row 


相关文章: 北京建设网站制作公司,北京古代建筑博物馆预约官网?  PHP 500报错的快速解决方法  济南企业网站制作公司,济南社保单位网上缴费步骤?  建站之星如何通过成品分离优化网站效率?  如何获取PHP WAP自助建站系统源码?  建站之星后台密码如何安全设置与找回?  西安大型网站制作公司,西安招聘网站最好的是哪个?  南宁网站建设制作定制,南宁网站建设可以定制吗?  如何用PHP工具快速搭建高效网站?  如何规划企业建站流程的关键步骤?  如何选择网络建站服务器?高效建站必看指南  道歉网站制作流程,世纪佳缘致歉小吴事件,相亲网站身份信息伪造该如何稽查?  如何通过NAT技术实现内网高效建站?  哪家制作企业网站好,开办像阿里巴巴那样的网络公司和网站要怎么做?  宝塔面板创建网站无法访问?如何快速排查修复?  定制建站流程解析:需求评估与SEO优化功能开发指南  详解jQuery停止动画——stop()方法的使用  中山网站制作网页,中山新生登记系统登记流程?  如何零基础开发自助建站系统?完整教程解析  建站主机选择指南:服务器配置与SEO优化实战技巧  武汉网站制作费用多少,在武汉武昌,建面100平方左右的房子,想装暖气片,费用大概是多少啊?  一键网站制作软件,义乌购一件代发流程?  建站之星如何防范黑客攻击与数据泄露?  如何在IIS服务器上快速部署高效网站?  如何用VPS主机快速搭建个人网站?  如何快速搭建支持数据库操作的智能建站平台?  如何通过云梦建站系统实现SEO快速优化?  香港服务器如何优化才能显著提升网站加载速度?  建站之星如何取消后台验证码生成?  如何用西部建站助手快速创建专业网站?  招商网站制作流程,网站招商广告语?  购物网站制作费用多少,开办网上购物网站,需要办理哪些手续?  代购小票制作网站有哪些,购物小票的简要说明?  外贸公司网站制作,外贸网站建设一般有哪些步骤?  广州美橙建站如何快速搭建多端合一网站?  北京的网站制作公司有哪些,哪个视频网站最好?  如何在建站之星网店版论坛获取技术支持?  广德云建站网站建设方案与建站流程优化指南  油猴 教程,油猴搜脚本为什么会网页无法显示?  外贸公司网站制作哪家好,maersk船公司官网?  网站制作中优化长尾关键字挖掘的技巧,建一个视频网站需要多少钱?  如何快速搭建自助建站会员专属系统?  python的本地网站制作,如何创建本地站点?  成都网站制作公司哪家好,四川省职工服务网是做什么用?  ,购物网站怎么盈利呢?  深圳防火门网站制作公司,深圳中天明防火门怎么编码?  定制建站方案优化指南:企业官网开发与建站费用解析  高防服务器租用首荐平台,企业级优惠套餐快速部署  如何通过万网虚拟主机快速搭建网站?  大连网站制作公司哪家好一点,大连买房网站哪个好? 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。