#### 引入模块 ~~~ from pymysql import * ~~~ #### Connection 对象 * 用于建立与数据库的连接 * 创建对象：调用connect()方法 ~~~ conn=connect(参数列表) ~~~ * 参数host：连接的mysql主机，如果本机是'localhost' * 参数port：连接的mysql主机的端口，默认是3306 * 参数database：数据库的名称 * 参数user：连接的用户名 * 参数password：连接的密码 * 参数charset：通信采用的编码方式，推荐使用utf8 ##### 对象的方法 * close()关闭连接 * commit()提交 * cursor()返回Cursor对象，用于执行sql语句并获得结果 ## Cursor对象 * 用于执行sql语句，使用频度最高的语句为select、insert、update、delete * 获取Cursor对象：调用Connection对象的cursor()方法 ~~~ cs1=conn.cursor() ~~~ #### 对象的方法 * close()关闭 * execute(operation \[, parameters \])执行语句，返回受影响的行数，主要用于执行insert、update、delete语句，也可以执行create、alter、drop等语句 * fetchone()执行查询语句时，获取查询结果集的第一个行数据，返回一个元组 * fetchall()执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回 #### 对象的属性 * rowcount只读属性，表示最近一次execute()执行后受影响的行数 * connection获得当前连接对象 示例 ~~~ from pymysql import * # 创建Connection对象 conn = connect( host='localhost', port=3306, database='test', user='root', password='' ) # 获取Cursor对象 cs1 = conn.cursor() # 执行插入语句 #count = cs1.execute('insert into pt_user (openid) values ("bbbbbbb")') #print(count) # 受影响的行数 # 查询 #count = cs1.execute('select * from pt_user') # for i in range(count): # result = cs1.fetchone() # print(result) #(1, 'aaaa') (3, 'bbbbbbb') #result = cs1.fetchall() #print(result) # ((1, 'aaaa'), (3, 'bbbbbbb')) # 参数化 params = [1] count = cs1.execute('select * from pt_user where id > %s', params) result = cs1.fetchall() print(result) # 提交之前的操作 查询可以不写 conn.commit() # 关闭Cursor对象 cs1.close() # 关闭Connection对象 conn.commit() ~~~