MySQL与python交互

一) 交互类型

-1. 安装引入模块

• 安装mysql模块(Ubuntu) : sudo apt-get install python-mysqldb
• 在文件中引入模块 : import MySQLdb

-2. Connection对象

• 用于监理与数据库的连接

  • 创建对象: 调用connect()方法 : conn = connect(参数列表)
  • 参数host: 连接的mysql主机, 如果本机是'localhost'
  • 参数port: 连接的mysql主机的端口, 默认是3306
  • 参数db: 数据库的名称
  • 参数passwd: 连接的密码
  • 参数charset: 通信采用的编码方式, 推荐使用utf8

• 对象的方法 :

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

  执行sql语句
  创建对象 : 调用Connection对象的cursor()方法 cursor1=conn.cursor

  • 1> 对象的方法 :
    • close()关系
    • execute(operation [, parameters ])执行语句, 返回受影响的行数
    • fetchone()执行查询语句时, 获取查询结果集的第一个行数据, 返回一个元组
    • next()执行查询语句时, 获取当前行的下一行
    • fetchall()执行查询语句时, 获取结果集的所有行, 一行构成一个元组, 再将这些元组装如意个元组返回
    • scroll(value[,mode])将行指针移动到某个位置
      • mode: 表示移动的方式
      • mode的默认值为relative, 表示基于当前行移动到value, value为正则向下移动, value为负则向上移动
      • mode的值为absolute, 表示基于第一条数据的位置, 第一条数据的位置为0
    • 2> 对象的属性
      • rowcount : 只读属性, 表示最近一次execute()执行后受影响的行数
      • connection获得当前连接对象

二) 增改删

-1. 增加:

• 增加testInsert.py文件, 向学生表中插入一条数据

#encoding=utf-8
import MySQLdb
try:
  conn=MySQL.connect(host='localhost', port=3306, db='test1', user='root', passwd='1', charset='utf8')
  cs1 = conn.cursor()
  sql = 'insert into students(sname) values('adam')'
  count = cs1.execute(sql)
  print count
  conn.commit()
  cs1.close()
  conn.close()
except Exception,e:
  print e.message

-2. 修改:

• 创建testUpdate.py文件, 更新学生表的一条数据

#encoding=utf-8
import MySQLdb
try:
  conn=MySQL.connect(host='localhost', port=3306, db='test1', user='root', passwd='1', charset='utf8')
  cs1 = conn.cursor()
  sql = 'update students set sname='jack' where id = 1'
  count = cs1.execute(sql)
  print count
  conn.commit()
  cs1.close()
  conn.close()
except Exception,e:
  print e.message

-3. 删除:

• 删除testDelete.py文件, 删除学生表的一条数据

#encoding=utf-8
import MySQLdb
try:
  conn=MySQL.connect(host='localhost', port=3306, db='test1', user='root', passwd='1', charset='utf8')
  cs1 = conn.cursor()
  sql = 'delete from students where id = 1'
  count = cs1.execute(sql)
  print count
  conn.commit()
  cs1.close()
  conn.close()
except Exception,e:
  print e.message

-4. sql语句参数化:

• 删除testInsertParam.py文件, 向学生表中插入一条数据(注意数据库安全-(攻击方式叫做: sql录入))

#encoding=utf-8
import MySQLdb
try:
  conn=MySQL.connect(host='localhost', port=3306, db='test1', user='root', passwd='1', charset='utf8')
  cs1 = conn.cursor()
  sname = raw_input("请输入学生姓名 : ")
  params = [sname]
  sql = ('insert into students(sname) values(%s)', params)
  count = cs1.execute(sql)
  print count
  conn.commit()
  cs1.close()
  conn.close()
except Exception,e:
  print e.message

-5. 其他语句:

• cursor对象的excute()方法, 也可以用于执行create table等语句
• 建议在开发之初, 就创建好数据库表结构, 不要在这里执行