导航：首页 > 数据库 >

python连接数据库操作MySQL

发表于：2026-10-31 作者：千家信息网编辑

千家信息网最后更新 2026年10月31日，参考:http://www.liaoxuefeng.com/wiki/001374738125095c955c1e6d8bb493182103fac9270762a000/00139143513181

千家信息网最后更新 2026年10月31日python连接数据库操作MySQL

参考

:http://www.liaoxuefeng.com/wiki/001374738125095c955c1e6d8bb493182103fac9270762a000/001391435131816c6a377e100ec4d43b3fc9145f3bb8056000

http://www.cnblogs.com/fnng/p/3565912.html

一模块

mysql-connector-python：是MySQL官方的纯Python驱动；
MySQL-python：是封装了MySQL C驱动的Python驱动。

可以把两个都装上，使用的时候再决定用哪个：

$ pip install  mysql-connector-pythonpip install  MySQL-python

或者使用yum安装(包名我忘记了可以是使用yum search mysql去找)

yum install MySQL-python

测试是否按照好的驱动

#!/usr/bin/env python#coding:utf-8import systry:    import MySQLdb    print "MySQL python drivier is ok!"except Exception, e:    print e    sys.exit(1)finally:    sys.exit(1)

二、数据库中的表

show create table net_data; 可以查看

CREATE TABLE `net_data` (  `_id` int(11) NOT NULL AUTO_INCREMENT,  `create_date` datetime NOT NULL,  `province` varchar(64) NOT NULL,  `city` varchar(64) NOT NULL,  `net_type` enum('CTC','CNC','CMC','JK') NOT NULL,  `med` float NOT NULL,  `loss` float NOT NULL,  PRIMARY KEY (`_id`)) ENGINE=InnoDB AUTO_INCREMENT=15 DEFAULT CHARSET=utf8;

三先看插入的实例吧

作用，连接数据库插入一条数据

数据库插入一条数据

import MySQLdb........def insert_into_mysql(info):    conn= MySQLdb.Connect(            host='localhost',            port = 3306,            user='root',            passwd='12qwaszx',            db ='netmap',            charset='utf8',            )    cur = conn.cursor()    sqli = "insert into net_data (create_date,province,city,net_type,med,loss) values(%s,%s,%s,%s,%s,%s)"    cur.execute(sqli,(datetime.now(),'上海','上海','CTC','23','0'))    conn.commit()    cur.close()    conn.close()

同时插入多条数据

#info type is list 列表def insert_into_mysql(info):    conn= MySQLdb.Connect(            host='localhost',            port = 3306,            user='root',            passwd='12qwaszx',            db ='netmap',            charset='utf8',            )    cur = conn.cursor()    sqli = "insert into net_data (create_date,province,city,net_type,med,loss) values(%s,%s,%s,%s,%s,%s)"    cur.executemany(sqli,(info))    conn.commit()    cur.close()    conn.close()

四、查询实例(完成程序的一部分，完成的是一个统计报表发送的邮件的程序)

#!/usr/bin/env python#encoding=utf8#by cuizhiliang at 2016-04-29from datetime import datetime, timedeltaimport timefrom jinja2 import Templatefrom sendmail import SendHtmlEmailimport MySQLdbimport os,sysreload(sys)sys.setdefaultencoding("utf-8")g= {    'host': '127.0.0.1',    'port': 3306,    'user': 'zabbix',    'password': 'zabbix',    'db':'zabbix',}now= datetime.now()yesterday = now - timedelta(1)yest_clock = (datetime.now()  -timedelta(1)).strftime('%s')data = {}def select_mysql(cmd):    conn= MySQLdb.Connect(            host= g['host'],            port= g['port'],            user= g['user'],            passwd= g['password'],            db =g['db'],            charset='utf8',            )    #print cmd    cur = conn.cursor()    cur.execute(cmd)    res =cur.fetchall()    return res#zabbix 上用户列表def get_user_info():    cmd="select userid, alias,  name, type  from users;"    user_list = []    user_list= list(select_mysql(cmd))    print user_list    return user_listif __name__ == "__main__":        data["user"]= get_user_info()

五、注意:

1 插入数据库中文乱码连接数据的字符集一定要设定