在python中安装pymysql第三方库,经过pip install pymysql 命令进行安装。python
data_one = cur.fetchone() # 游标名.fetchone()mysql
data = cur.fetchall() # 游标名.fetchall()sql
import pymysql # 一、链接到数据库 con = pymysql.connect(host='ip', port=3306, user='test', password='test', database='future', charset='utf8') # 二、建立一个游标 cursor cur = con.cursor() # 三、执行对应的sql语句 execute() sql = 'select * from member ' # 查询到的数据条数 res = cur.execute(sql) print(res) # 四、获取查询到的数据 # 方法一:获取一条查询数据 data_one = cur.fetchone() print(data_one) # 方法二:获取全部的查询数据 data = cur.fetchall() print(data)
pymysql操做数据库,默认开启了事务,须要使用 con.commit() 进行提交事务,未提交的话,所作的操做不能生效。数据库
import pymysql from common.config import conf class ReadMySQLData(object): def __init__(self): # 链接到数据库 self.con = pymysql.connect(host=conf.get('mysql','host'), port=conf.getint('mysql','port'), user=conf.get('mysql','user'), password=conf.get('mysql','password'), database=conf.get('mysql','database'), charset='utf8') # 建立游标 self.cur= self.con.cursor() def find_one(self,sql): ''' 查找并返回找到的第一条数据,返回的数据类型是元组 :param sql: :return: ''' self.cur.execute(sql) self.con.commit() return self.cur.fetchone() def find_all(self,sql): ''' 查找并返回找到的全部数据,返回的数据类型是元组 :param sql: :return: ''' self.cur.execute(sql) self.con.commit() return self.cur.fetchall() def close(self): ''' 关闭游标,断开数据库链接 :return: ''' self.cur.close() self.con.close()