python连接数据库操作MySQL

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,高可用系列 2核4GB
简介:

参考

: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-python
pip install  MySQL-python

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

yum install MySQL-python



测试是否按照好的驱动

1
2
3
4
5
6
7
8
9
10
11
#!/usr/bin/env python
#coding:utf-8
import  sys
try :
     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; 可以查看


1
2
3
4
5
6
7
8
9
10
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;


三  先看插入的实例吧


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


数据库插入一条数据

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
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()




同时插入多条数据

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
#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()




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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
#!/usr/bin/env python
#encoding=utf8
#by cuizhiliang at 2016-04-29
from  datetime  import  datetime, timedelta
import  time
from  jinja2  import  Template
from  sendmail  import  SendHtmlEmail
import  MySQLdb
import  os,sys
reload (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_list
if  __name__  = =  "__main__" :
     
     data[ "user" ] =  get_user_info()


五、注意: 

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

1
charset = 'utf8'


2 不惯数据库中的字段是datetime类型还是int类型,在插入的时候都传为%s 字符串类型,类型对我们是透明了,模块会自动处理类型! 


3 模块在mac中可能会出错 MySQLdb 


报错:

Traceback (most recent call last):

  File "ping_info.py", line 12, in <module>

    import MySQLdb

  File "/Library/Python/2.7/site-packages/MySQLdb/__init__.py", line 19, in <module>

    import _mysql

ImportError: dlopen(/Library/Python/2.7/site-packages/_mysql.so, 2): Library not loaded: libmysqlclient.18.dylib

  Referenced from: /Library/Python/2.7/site-packages/_mysql.so

  Reason: image not found



解决方法,因为是C语言开发驱动,所有依赖mysql客户端模块

 sudo find / -name "libmysqlclient.18.dylib"

/usr/local/mysql-5.6.24-osx10.8-x86_64/lib/libmysqlclient.18.dylib

sudo cp /usr/local/mysql-5.6.24-osx10.8-x86_64/lib/libmysqlclient.18.dylib /usr/lib

本文转自残剑博客51CTO博客,原文链接http://blog.51cto.com/cuidehua/1764587如需转载请自行联系原作者


cuizhiliang

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
1月前
|
关系型数据库 MySQL Java
【YashanDB知识库】原生mysql驱动配置连接崖山数据库
【YashanDB知识库】原生mysql驱动配置连接崖山数据库
【YashanDB知识库】原生mysql驱动配置连接崖山数据库
|
1月前
|
关系型数据库 MySQL 数据库连接
docker拉取MySQL后数据库连接失败解决方案
通过以上方法,可以解决Docker中拉取MySQL镜像后数据库连接失败的常见问题。关键步骤包括确保容器正确启动、配置正确的环境变量、合理设置网络和权限,以及检查主机防火墙设置等。通过逐步排查,可以快速定位并解决连接问题,确保MySQL服务的正常使用。
310 82
|
3天前
|
负载均衡 算法 关系型数据库
大数据新视界--大数据大厂之MySQL数据库课程设计:MySQL集群架构负载均衡故障排除与解决方案
本文深入探讨 MySQL 集群架构负载均衡的常见故障及排除方法。涵盖请求分配不均、节点无法响应、负载均衡器故障等现象,介绍多种负载均衡算法及故障排除步骤,包括检查负载均衡器状态、调整算法、诊断修复节点故障等。还阐述了预防措施与确保系统稳定性的方法,如定期监控维护、备份恢复策略、团队协作与知识管理等。为确保 MySQL 数据库系统高可用性提供全面指导。
|
8天前
|
SQL 关系型数据库 MySQL
大数据新视界--大数据大厂之MySQL数据库课程设计:MySQL 数据库 SQL 语句调优方法详解(2-1)
本文深入介绍 MySQL 数据库 SQL 语句调优方法。涵盖分析查询执行计划,如使用 EXPLAIN 命令及理解关键指标;优化查询语句结构,包括避免子查询、减少函数使用、合理用索引列及避免 “OR”。还介绍了索引类型知识,如 B 树索引、哈希索引等。结合与 MySQL 数据库课程设计相关文章,强调 SQL 语句调优重要性。为提升数据库性能提供实用方法,适合数据库管理员和开发人员。
|
7天前
|
关系型数据库 MySQL 大数据
大数据新视界--大数据大厂之MySQL 数据库课程设计:MySQL 数据库 SQL 语句调优的进阶策略与实际案例(2-2)
本文延续前篇,深入探讨 MySQL 数据库 SQL 语句调优进阶策略。包括优化索引使用,介绍多种索引类型及避免索引失效等;调整数据库参数,如缓冲池、连接数和日志参数;还有分区表、垂直拆分等其他优化方法。通过实际案例分析展示调优效果。回顾与数据库课程设计相关文章,强调全面认识 MySQL 数据库重要性。为读者提供综合调优指导,确保数据库高效运行。
|
1月前
|
消息中间件 缓存 NoSQL
缓存与数据库的一致性方案,Redis与Mysql一致性方案,大厂P8的终极方案(图解+秒懂+史上最全)
缓存与数据库的一致性方案,Redis与Mysql一致性方案,大厂P8的终极方案(图解+秒懂+史上最全)
|
1月前
|
SQL 关系型数据库 MySQL
MySQL生产环境迁移至YashanDB数据库深度体验
这篇文章是作者将 MySQL 生产环境迁移至 YashanDB 数据库的深度体验。介绍了 YashanDB 迁移平台 YMP 的产品相关信息、安装步骤、迁移中遇到的各种兼容问题及解决方案,最后总结了迁移体验,包括工具部署和操作特点,也指出功能有优化空间及暂不支持的部分,期待其不断优化。
|
2月前
|
关系型数据库 MySQL 网络安全
如何排查和解决PHP连接数据库MYSQL失败写锁的问题
通过本文的介绍,您可以系统地了解如何排查和解决PHP连接MySQL数据库失败及写锁问题。通过检查配置、确保服务启动、调整防火墙设置和用户权限,以及识别和解决长时间运行的事务和死锁问题,可以有效地保障应用的稳定运行。
187 25
|
2月前
|
监控 关系型数据库 MySQL
云数据库:从零到一,构建高可用MySQL集群
在互联网时代,数据成为企业核心资产,传统单机数据库难以满足高并发、高可用需求。云数据库通过弹性扩展、分布式架构等优势解决了这些问题,但也面临数据安全和性能优化挑战。本文介绍了如何从零开始构建高可用MySQL集群,涵盖选择云服务提供商、创建实例、配置高可用架构、数据备份恢复及性能优化等内容,并通过电商平台案例展示了具体应用。
|
1月前
|
存储 SQL 关系型数据库
从 MySQL 到时序数据库 TDengine:Zendure 如何实现高效储能数据管理?
TDengine 助力广州疆海科技有限公司高效完成储能业务的数据分析任务,轻松应对海量功率、电能及输入输出数据的实时统计与分析,并以接近 1 : 20 的数据文件压缩率大幅降低存储成本。此外,taosX 强大的 transform 功能帮助用户完成原始数据的清洗和结构优化,而其零代码迁移能力更实现了历史数据从 TDengine OSS 与 MySQL 到 TDengine 企业版的平滑迁移,全面提升了企业的数据管理效率。本文将详细解读这一实践案例。
52 0

热门文章

最新文章

下一篇
oss创建bucket