欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Python操作mysql方法说明

程序员文章站 2022-05-25 16:10:02
...
python支持连接多种数据库:如下:
GadFly,mSQL,MySQL,PostgreSQL,Microsoft SQL Server 2000,Informix,Interbase,Oracle,Sybase

如果要操作mysql需要先安装MySQLdb,MySQLdb是用于Python链接Mysql数据库的接口,它实现了 Python 数据库 API 规范.

一、MySQLdb安装

检测python中是否已安装mysqldb的方法,只要在客户端执行import MySQLdb看是否报错就行,如果不报错说明已安装,如果报ImportError: No module named MySQLdb, 说明没有安装

安装mysqldb方法:linux平台先到https://pypi.python.org/pypi/MySQL-python上下载相应版本

如果您选择二进制文件发行版本的话,安装过程基本安装提示即可完成。如果从源代码进行安装的话,则需要切换到MySQLdb发行版本的*目录,并键入下列命令:
$ gunzip MySQL-python-1.2.2.tar.gz
$ tar -xvf MySQL-python-1.2.2.tar
$ cd MySQL-python-1.2.2
$ python setup.py build
$ python setup.py install
注意:请确保您有root权限来安装上述模块。


二、连接mysql数据库

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db=MySQLdb.connect(host='hostIp',port=dbPort,user='dbusername',passwd='dbpassword', db='databasename', charset="utf8")

# 使用cursor()方法获取操作游标
cursor = db.cursor()

# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")

返回结果为记录数条数:1L

#print "Database version : %s " % data

# 使用 fetchone() 方法获取一条数据
data = cursor.fetchone()

print "Database version : %s " % data

# 关闭数据库连接
db.close()

三、创建数据库表

# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS TEST")

# 创建数据表SQL语句
sql = """CREATE TABLE TEST(
         ID INT NOT NULL,
         NAME VARCHAR(20) )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()


四、插入数据库

# SQL 插入语句
sql = """INSERT INTO TEST(ID,NAME)
         VALUES (1, 'zhangsan')"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # Rollback in case there is any error
   db.rollback()

# 关闭数据库连接
db.close()

sql也可能通过变量传参的方式写入值:
sql = "INSERT INTO TEST(ID, NAME) \
       VALUES ('%d', '%s')" % \
       (1, 'zhangsan')

五、数据库查询操作

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。
fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall():接收全部的返回结果行.
rowcount: 这是一个只读属性,并返回执行execute()方法后影响的行数


# SQL 查询语句
sql = "SELECT * FROM TEST \
       WHERE ID> '%d'" % (1000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      ID= row[0]
      NAME= row[1]
      # 打印结果
      print "ID=%d,NAME=%s"%(ID, NAME)
except:
   print "Error: unable to fecth data"

# 关闭数据库连接
db.close()