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()
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()
上一篇: 介绍 win8 开发的一些文章