python操作MySQL流程

安装引入模块

• 安装pymysql模块

sudo apt install python-mysql

• 在文件中引入模块

import Mysqldb

Connection对象

• 用于建立与数据库的连接
• 创建对象：调用connect()方法

conn=connect(参数列表)

• 参数host：连接的mysql主机，如果本机是'localhost'
• 参数port：连接的mysql主机的端口，默认是3306
• 参数db：数据库的名称
• 参数user：连接的用户名
• 参数password：连接的密码
• 参数charset：通信采用的编码方式，默认是'gb2312'，要求与数据库创建时指定的编码一致，否则中文会乱码

对象的方法

• close()关闭连接
• commit()事务，所以需要提交才会生效
• rollback()事务，放弃之前的操作
• cursor()返回Cursor对象，用于执行sql语句并获得结果

Cursor对象

• 执行sql语句
• 创建对象：调用Connection对象的cursor()方法

cursor1=conn.cursor()

对象的方法

• close()关闭
• execute(operation [, parameters ])执行语句，返回受影响的行数
  • cursor对象的execute（）方法，也可以用于执行create table etc语句
• fetchone()执行查询语句时，获取查询结果集的第一个行数据，返回一个元组
• next()执行查询语句时，获取当前行的下一行
• fetchall()执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回
• scroll(value[,mode])将行指针移动到某个位置
  • mode表示移动的方式
  • mode的默认值为relative，表示基于当前行移动到value，value为正则向下移动，value为负则向上移动
  • mode的值为absolute，表示基于第一条数据的位置，第一条数据的位置为0

对象的属性

• rowcount只读属性，表示最近一次execute()执行后受影响的行数
• connection获得当前连接对象

python执行数据库查询demo

# encoding=utf-8

from pymysql import *

def main():
    # 创建连接 
    conn = connect(
        host='localhost', 
        port=3306,
        user='root',
        password='******',
        database='test'
        )
    # 获取Cursor对象
    cs1 = conn.cursor()
    # count = cs1.execute('select id, name from students where id<4')
    yuju = input("请输入SQL语句:")
    # 执行sql语句
    count = cs1.execute(yuju)
    print('查询到%s条数据：' %count)

    for i in range(count):
        # fetchone按照元组每次一条数据返回
        # fetchall()返回全部 
        # fetchmany(3)返回一个元组，里面包含3个元组信息
        result = cs1.fetchone()
        print(result)

    # result = cs1.fetchall()
    # print(result)    

    cs1.close()
    conn.close()

if __name__ == "__main__":
    main()      

# python