12.python之pymsql模块

一、pymysql模块的简介。

pymysql是python3.x版本用来操作mysql数据库的一个模块,其实和python2.7中的MySQLdb模块的作用和操作语法都是一模一样的。

可以通过pip来进行安装:

pip3.5 install pymysql

pymysql这种数据库接口的使用,大概分为4个步骤:

执行连接数据库->执行query->提取数据->关闭连接

在使用pymysql这个模块时,你需要注意的。

  1. Connection 连接对象。

    虽然在MySQLdb.Connect(host ,user , passw , db)函数中,我们经常使用的只是这几个参数,但是其实里面还有很多比如字符集、线程安全、ssl等也都是很重要的参数,使用时要身份注意。

  2. commit 提交。

    对于mysql来说,如果使用支持事务的存储引擎,那么每次操作后,commit是必须的,否则不会真正写入数据库,对应rollback可以进行相应的回滚,但是commit后是无法再rollback的。commit() 可以在执行很多sql指令后再一次调用,这样可以适当提升性能。

二、使用示例:

安装好了之后,import导入。

import pymysql

#创建与数据库的连接。

sql_conn=pymysql.connect(host=‘10.39.0.5‘,port=3306,user=‘root‘,passwd=‘123456‘,db=‘db_1‘)

#创建游标对象。

cursor = sql_conn.cursor()

hire_start = datetime.date(1999, 1, 1)

hire_end = datetime.date(2016, 12, 31)

#执行sql语句。

sql = ‘SELECT first_name, last_name, hire_date FROM employees WHERE hire_date BETWEEN %s AND %s‘  %(hire_start,hire_end)

cursor.execute(sql)

#获取查询结果:

如果做的是select查询操作的话,在游标对象中execute这个查询语句后,会返回一个结果集。

返回的这个结果集中,是有指针概念的。

#one=cursor.fetchone() #只获取结果集中的第一条记录。(获取当前指针所在位置向下的一条记录。)(获取一条结果后,指针会向下移动一条记录)

#many=cursor.fetchmany(2)#以当前指针位置为基准,从结果集中向下获取几条记录。

all=cursor.fetchall()#以当前指针位置为基准,一直获取到结果集结束的位置。(也可以理解为获取结果集中所有的结果。)

scroll 移动指针:

#cursor.scroll(-1,mode=‘relative‘)  # 相对当前位置移动

#cursor.scroll(2,mode=‘absolute‘) # 相对绝对位置移动

mode为relative时是根据相对位置来移动指针的,整数代表向前移动几行,负数代表向后移动几行。

mode为absolute时是根据绝对位置来移动指针的,前面的数字为几,就会移动到结果集的第几行。

!!!更改获取结果的数据类型:

#更改获取数据结果的数据类型,默认是元组,可以改为字典等:conn.cursor(cursor=pymysql.cursors.DictCursor)

commit & close:

对于mysql来说,如果使用支持事务的存储引擎,那么每次操作后,commit是必须的,否则不会真正写入数据库,对应rollback可以进行相应的回滚,但是commit后是无法再rollback的。commit() 可以在执行很多sql指令后再一次调用,这样可以适当提升性能。

sql_conn.commit() #提交

cursor.close() #关闭游标

sql_conn.close() #关闭连接

时间: 2024-08-09 06:33:39

12.python之pymsql模块的相关文章

python基础教程_学习笔记12:充电时刻——模块

充电时刻--模块 python的标准安装包括一组模块,称为标准库. 模块 >>> import math >>> math.sin(0) 0.0 模块是程序 任何python程序都可以作为模块导入. $ cat hello.py #!/usr/bin/python print "Hello,signjing!" $ ./hello.py Hello,signjing! 假设将python程序保存在/home/ggz2/magiccube/mysh/p

Python中time模块详解

在Python中,与时间处理有关的模块就包括:time,datetime以及calendar.这篇文章,主要讲解time模块. 在开始之前,首先要说明这几点: 在Python中,通常有这几种方式来表示时间:1)时间戳 2)格式化的时间字符串 3)元组(struct_time)共九个元素.由于Python的time模块实现主要调用C库,所以各个平台可能有所不同. UTC(Coordinated Universal Time,世界协调时)亦即格林威治天文时间,世界标准时间.在中国为UTC+8.DST

PYTHON学习第二模块 python内置模块介绍

1 >>> import time 2 >>> time.time() 3 1491064723.808669 4 >>> # time.time()返回当前时间的时间戳timestamp(定义为从格林威治时间1970年01月01日00时00分00秒起至现在的总秒数)的方法,无参数 5 >>> time.asctime() 6 'Sun Apr 2 00:39:32 2017' 7 >>> # time.asctim

Python(六)-常用模块

目录: 1.模块介绍 2.time & datetime模块 3.rendom 4.os 5.sys 6.shutil 7.json & picle 8.shelve 9.xml处理 10.yaml处理 11.chonfigparser 12.hashlib 13.subprocess 14.logging模块 15.re正则表达式 第一章:模块介绍 模块,用一坨代码实现了某个功能的代码集合. 类似于函数式编程和面向过程编程,函数式编程则完成一个功能,其他代码用来调用即可,提供了代码的重用

安装Python的psutil模块时报错:error: command 'gcc' failed with exit status 1

安装Python的psutil模块: tar zxvf psutil-2.0.0.tar.gz cd psutil-2.0.0 python setup.py install 报错: running install running bdist_egg ...... psutil/_psutil_linux.c:12:20: error: Python.h: No such file or directory In file included from psutil/_psutil_linux.c

python的logging模块

1.简单的将日志打印到屏幕 import logging logging.debug('This is debug message') logging.info('This is info message') logging.warning('This is warning message') 屏幕上打印: WARNING:root:Thisis warning message 默认情况下,logging将日志打印到屏幕,日志级别为WARNING: 日志级别大小关系为:CRITICAL > ER

python之socket模块

UDP client #!/usr/bin/env python2.7 #-*-coding:utf-8 -*- import socket s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) s.sendto("hello",("localhost",8001)) data,addr = s.recvfrom(1024) print "receive data:%s from %s" % (dat

python基础之模块二

六 logging模块 6.1 函数式简单配置 import logging #导入模块 logging.debug('debug message') #调试消息 logging.debug('info message') #导入消息 logging.debug('warning message') #警告消息 logging.error('error message') #错误消息 logging.critical('critical message') #严重信息 默认情况下python的l

python中threading模块详解(一)

python中threading模块详解(一) 来源 http://blog.chinaunix.net/uid-27571599-id-3484048.html threading提供了一个比thread模块更高层的API来提供线程的并发性.这些线程并发运行并共享内存. 下面来看threading模块的具体用法: 一.Thread的使用 目标函数可以实例化一个Thread对象,每个Thread对象代表着一个线程,可以通过start()方法,开始运行. 这里对使用多线程并发,和不适用多线程并发做