db.close后还能操作db数据库查看器吗

来源：蜘蛛抓取(WebSpider) 时间：2014-10-24 08:10 标签： db数据库编辑器
查看:3731|回复：5
自己写了个DBManager管理c3p0数据源，理论上从DBManager里面获取的Connection使用完之后执行close()方法会把connection标记为闲置，而不是销毁。 但是我自己的测试代码结果却相反，每次的connection对象都不一样！！ 请高手解析下为什么会这样，要怎么做才可以实现每次的Connection都一样呢？
DBManager代码
package ben.DBU
import java.sql.C
import java.sql.DatabaseMetaD
import java.sql.SQLE
import java.util.HashM
import java.util.HashS
import java.util.P
import java.util.S
import com.mchange.boPooledDataS
import org.apache.log4j.L
* Created with IntelliJ IDEA.
* User: Ben
* Date: 13-7-3
* Time: 下午5:06
* To change this template use File | Settings | File Templates.
public class DBManager {
& & & & //保存数据库连接池的容器
& & & & private static HashMap&String, ComboPooledDataSource& datasourceMap = new HashMap&String, ComboPooledDataSource&();
& & & & private final static ThreadLocal&Connection& conns = new ThreadLocal&Connection&();
& & & & private static Logger logger = Logger.getLogger(DBManager.class);
& & & & static {
& & & & & & & & InitDataSource(null);
& & & & /**
& & & &&&* 初始化连接池
& & & &&&* */
& & & & private final static void InitDataSource(Properties dbProperties){
& & & & & & & & try{
& & & & & & & & & & & & if (dbProperties == null){
& & & & & & & & & & & & & & & & dbProperties = new Properties();
& & & & & & & & & & & & & & & & dbProperties.load(DBManager.class.getClassLoader().getResourceAsStream(&dbInfo.properties&));
& & & & & & & & & & & & }
& & & & & & & & & & & & //获取数据源名称
& & & & & & & & & & & & Set&String& keys = new HashSet&String&();
& & & & & & & & & & & & for (Object key : dbProperties.keySet()){
& & & & & & & & & & & & & & & & String skey = (String)
& & & & & & & & & & & & & & & & Integer point = skey.indexOf(&.&);
& & & & & & & & & & & & & & & & keys.add(skey.substring(0, point));
& & & & & & & & & & & & }
& & & & & & & & & & & & //实例化DataSource并放入容器中
& & & & & & & & & & & & for (String key : keys)
& & & & & & & & & & & & {
& & & & & & & & & & & & & & & & ComboPooledDataSource ds = new ComboPooledDataSource();
& & & & & & & & & & & & & & & & ds.setDriverClass(dbProperties.getProperty(key + &.& + &Driver&));
& & & & & & & & & & & & & & & & ds.setJdbcUrl(dbProperties.getProperty(key + &.& + &Url&));
& & & & & & & & & & & & & & & & ds.setUser(dbProperties.getProperty(key + &.& + &User&));
& & & & & & & & & & & & & & & & ds.setPassword(dbProperties.getProperty(key + &.& + &Password&));
& & & & & & & & & & & & & & & & ds.setMaxPoolSize(Integer.parseInt(dbProperties.getProperty(key + &.& + &MaxPoolSize&)));
& & & & & & & & & & & & & & & & ds.setMinPoolSize(Integer.parseInt(dbProperties.getProperty(key + &.& + &MinPoolSize&)));
& & & & & & & & & & & & & & & & ds.setMaxIdleTime(Integer.parseInt(dbProperties.getProperty(key + &.& + &MaxIdleTime&)));
& & & & & & & & & & & & & & & & ds.setInitialPoolSize(Integer.parseInt(dbProperties.getProperty(key + &.& + &InitialPoolSize&)));
& & & & & & & & & & & & & & & & ds.setAcquireIncrement(Integer.parseInt(dbProperties.getProperty(key + &.& + &AcquireIncrement&)));
& & & & & & & & & & & & & & & & ds.setAcquireRetryAttempts(Integer.parseInt(dbProperties.getProperty(key + &.& + &AcquireRetryAttempts&)));
& & & & & & & & & & & & & & & & ds.setAcquireRetryDelay(Integer.parseInt(dbProperties.getProperty(key + &.& + &AcquireRetryDelay&)));
& & & & & & & & & & & & & & & & ds.setMaxStatements(Integer.parseInt(dbProperties.getProperty(key + &.& + &MaxStatements&)));
& & & & & & & & & & & & & & & & ds.setIdleConnectionTestPeriod(Integer.parseInt(dbProperties.getProperty(key + &.& + &IdleConnectionTestPeriod&)));
& & & & & & & & & & & & & & & & ds.setCheckoutTimeout(Integer.parseInt(dbProperties.getProperty(key + &.& + &CheckoutTimeout&)));
& & & & & & & & & & & & & & & & ds.setTestConnectionOnCheckin(Boolean.parseBoolean(dbProperties.getProperty(key + &.& + &TestConnectionOnCheckin&)));
& & & & & & & & & & & & & & & & ds.setTestConnectionOnCheckout(Boolean.parseBoolean(dbProperties.getProperty(key + &.& + &TestConnectionOnCheckout&)));
& & & & & & & & & & & & & & & & datasourceMap.put(key, ds);
& & & & & & & & & & & & & & & & Connection conn = getConnection(key);
& & & & & & & & & & & & & & & & DatabaseMetaData metaData = conn.getMetaData();
& & & & & & & & & & & & & & & & (&Using DataSource: & + conn.getClass().getName());
& & & & & & & & & & & & & & & & closeConnection();
& & & & & & & & & & & & }
& & & & & & & & }
& & & & & & & & catch (Exception e){
& & & & & & & & & & & & logger.error(&DataSource Error:& + e.toString());
& & & & & & & & }
& & & & /**
& & & &&&* 断开连接池
& & & &&&* */
& & & & public&&final static&&void closeDataSource(String dataSourceName){
& & & & & & & & try{
& & & & & & & & & & & & ComboPooledDataSource dataSource = datasourceMap.get(dataSourceName);
& & & & & & & & & & & & dataSource.close();
& & & & & & & & }
& & & & & & & & catch (Exception e){
& & & & & & & & & & & & logger.error(&Unable to destroy DataSource! & + e.toString());
& & & & & & & & }
& & & & /**
& & & &&&* 获取连接
& & & &&&*
Connection
& & & &&&* */
& & & & public final static Connection getConnection(String dataSourceName) throws SQLException{
& & & & & & & & Connection conn = conns.get();
& & & & & & & & if (conn == null || conn.isClosed()){
& & & & & & & & & & & & ComboPooledDataSource dataSource = datasourceMap.get(dataSourceName);
& & & & & & & & & & & & conn = dataSource.getConnection();
& & & & & & & & & & & & conns.set(conn);
& & & & & & & & }
& & & & & & & &
& & & & /**
& & & &&&* 关闭连接
& & & &&&* */
& & & & public final static void closeConnection(){
& & & & & & & & Connection conn = conns.get();
& & & & & & & & try{
& & & & & & & & & & & & if (conn != null && !conn.isClosed()){
& & & & & & & & & & & & & & & & conn.setAutoCommit(true);
& & & & & & & & & & & & & & & & conn.close();
& & & & & & & & & & & & }
& & & & & & & & }
& & & & & & & & catch (SQLException ex){
& & & & & & & & & & & & logger.error(&Unable to close connection! & + ex.toString());
& & & & & & & & }
& & & & & & & & finally {
& & & & & & & & & & & & conns.remove();
& & & & & & & & & & & & //conns.set(null);
& & & & & & & & }
& & & & /**
& & & &&&* 开启事务非自动提交
& & & &&&* */
& & & & public final static void startTransaction(String dataSourceName){
& & & & & & & & try{
& & & & & & & & & & & & Connection conn = conns.get();
& & & & & & & & & & & & if (conn == null){
& & & & & & & & & & & & & & & & ComboPooledDataSource dataSource = datasourceMap.get(dataSourceName);
& & & & & & & & & & & & & & & & conn = dataSource.getConnection();
& & & & & & & & & & & & & & & & conns.set(conn);
& & & & & & & & & & & & }
& & & & & & & & & & & & conn.setAutoCommit(false);
& & & & & & & & }
& & & & & & & & catch (Exception ex){
& & & & & & & & & & & & logger.error(&Can't get the connection! & + ex.toString());
& & & & & & & & & & & & throw new RuntimeException(ex);
& & & & & & & & }
& & & & /**
& & & &&&* 提交事务
& & & &&&* */
& & & & public final static void commitTransaction(){
& & & & & & & & try{
& & & & & & & & & & & & Connection conn = conns.get();
& & & & & & & & & & & & if (conn != null){
& & & & & & & & & & & & & & & & mit();
& & & & & & & & & & & & }
& & & & & & & & }
& & & & & & & & catch (Exception ex){
& & & & & & & & & & & & logger.error(&Can't commit the transaction ! & + ex.toString());
& & & & & & & & & & & & throw new RuntimeException(ex);
& & & & & & & & }
dbInfo.properties
DemoData.AcquireIncrement& && && &= 2
DemoData.AcquireRetryAttempts& &&&= 30
DemoData.AcquireRetryDelay& && &&&= 1000
DemoData.CheckoutTimeout& && && & = 3000
DemoData.Driver& && && && && && & = com.microsoft.sqlserver.jdbc.SQLServerDriver
DemoData.IdleConnectionTestPeriod = 18000
DemoData.InitialPoolSize& && && & = 2
DemoData.MaxIdleTime& && && && &&&= 300
DemoData.MaxPoolSize& && && && &&&= 100
DemoData.MaxStatements& && && && &= 1000
DemoData.MinPoolSize& && && && &&&= 2
DemoData.Password& && && && && &&&= 123
DemoData.TestConnectionOnCheckin&&= false
DemoData.TestConnectionOnCheckout = false
DemoData.Url& && && && && && && & = jdbc:sqlserver://localhost:1433;DatabaseName=DemoData
DemoData.User& && && && && && && &= sa
测试代码package ben.DBU
import java.sql.C
* Created with IntelliJ IDEA.
* User: Ben
* Date: 13-7-6
* Time: 上午12:28
* To change this template use File | Settings | File Templates.
public class TestDBManager {
& & & & public static void main(String[] args) {
& & & & & & & & for (Integer i=0; i&12; i++){
& & & & & & & & & & & & try{
& & & & & & & & & & & & & & & & System.out.println(DBManager.getConnection(&DemoData&));
& & & & & & & & & & & & & & & & DBManager.closeConnection();
& & & & & & & & & & & & & & & & System.out.println(&---------------------------&);
& & & & & & & & & & & & & & & & System.out.println(DBManager.getConnection(&DemoData&));
& & & & & & & & & & & & & & & & DBManager.closeConnection();
& & & & & & & & & & & & & & & & System.out.println(&---------------------------&);
& & & & & & & & & & & & }
& & & & & & & & & & & & catch (Exception ex){
& & & & & & & & & & & & & & & & ex.printStackTrace();
& & & & & & & & & & & & }
& & & & & & & & }
构想中，打印出来的应该结构应该是相同的，才说明重复使用了连接。但是怎么打印出来的都不一样呢？
com.mchange.v2.c3p0.impl.NewProxyConnection@ff5c225
com.mchange.v2.c3p0.impl.NewProxyConnection@ff5c225
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@5bafcc2c
com.mchange.v2.c3p0.impl.NewProxyConnection@5bafcc2c
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@ded0b93
com.mchange.v2.c3p0.impl.NewProxyConnection@ded0b93
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@25057fe
com.mchange.v2.c3p0.impl.NewProxyConnection@25057fe
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@198ad24a
com.mchange.v2.c3p0.impl.NewProxyConnection@198ad24a
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@1228bd68
com.mchange.v2.c3p0.impl.NewProxyConnection@1228bd68
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@36db09fa
com.mchange.v2.c3p0.impl.NewProxyConnection@36db09fa
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@35886ba1
com.mchange.v2.c3p0.impl.NewProxyConnection@35886ba1
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@17d8986
com.mchange.v2.c3p0.impl.NewProxyConnection@17d8986
---------------------------
com.mchange.v2.c3p0.impl.NewProxyConnection@2bb9e538
com.mchange.v2.c3p0.impl.NewProxyConnection@2bb9e538
---------------------------
本帖最后由 greatbensharp 于
17:33 编辑
这代码贴出来怎么是这样？
引用:原帖由 super小邪 于
13:17 发表
这代码贴出来怎么是这样？ 不好意思，代码重新发了
这让我想起了刚开始学做连接池的时候
引用:原帖由 super小邪 于
17:43 发表
这让我想起了刚开始学做连接池的时候 那高手你看这代码有什么问题呢？
引用:原帖由 greatbensharp 于
10:57 发表
那高手你看这代码有什么问题呢？ 只是以前做过，谈不上高手。我也没弄明白，为什么，同一次循环输出是一样，下一次循环就不一样了125791人阅读
iOS开发（19）
FMDB (在FMDB下载文件后，工程中必须导入如下文件，并使用FMDB常用类：FMDatabase ： 一个单一的SQLite数据库，用于执行SQL语句。FMResultSet ：执行查询一个FMDatabase结果集，这个和android的Cursor类似。FMDatabaseQueue ：在多个线程来执行查询和更新时会使用这个类。创建数据库：db = [FMDatabase databaseWithPath:database_path];。打开数据库：[db open]返回BOOL型。关闭数据库：[db close]数据库增删改等操作：除了查询操作，FMDB数据库操作都执行executeUpdate方法，这个方法返回BOOL型。看一下例子：创建表：if ([db open]) {
NSString *sqlCreateTable =
[NSString stringWithFormat:@&CREATE TABLE IF NOT EXISTS '%@' ('%@' INTEGER PRIMARY KEY AUTOINCREMENT, '%@' TEXT, '%@' INTEGER, '%@' TEXT)&,TABLENAME,ID,NAME,AGE,ADDRESS];
BOOL res = [db executeUpdate:sqlCreateTable];
if (!res) {
NSLog(@&error when creating db table&);
NSLog(@&success to creating db table&);
[db close];
添加数据： if ([db open]) {
NSString *insertSql1= [NSString stringWithFormat:
@&INSERT INTO '%@' ('%@', '%@', '%@') VALUES ('%@', '%@', '%@')&,
TABLENAME, NAME, AGE, ADDRESS, @&张三&, @&13&, @&济南&];
BOOL res = [db executeUpdate:insertSql1];
NSString *insertSql2 = [NSString stringWithFormat:
@&INSERT INTO '%@' ('%@', '%@', '%@') VALUES ('%@', '%@', '%@')&,
TABLENAME, NAME, AGE, ADDRESS, @&李四&, @&12&, @&济南&];
BOOL res2 = [db executeUpdate:insertSql2];
if (!res) {
NSLog(@&error when insert db table&);
NSLog(@&success to insert db table&);
[db close];
修改数据：if ([db open]) {
NSString *updateSql = [NSString stringWithFormat:
@&UPDATE '%@' SET '%@' = '%@' WHERE '%@' = '%@'&,
TABLENAME,
@&15& ,AGE,
BOOL res = [db executeUpdate:updateSql];
if (!res) {
NSLog(@&error when update db table&);
NSLog(@&success to update db table&);
[db close];
删除数据：if ([db open]) {
NSString *deleteSql = [NSString stringWithFormat:
@&delete from %@ where %@ = '%@'&,
TABLENAME, NAME, @&张三&];
BOOL res = [db executeUpdate:deleteSql];
if (!res) {
NSLog(@&error when delete db table&);
NSLog(@&success to delete db table&);
[db close];
数据库查询操作：查询操作使用了executeQuery，并涉及到if ([db open]) {
NSString * sql = [NSString stringWithFormat:
@&SELECT * FROM %@&,TABLENAME];
FMResultSet * rs = [db executeQuery:sql];
while ([rs next]) {
int Id = [rs intForColumn:ID];
NSString * name = [rs stringForColumn:NAME];
NSString * age = [rs stringForColumn:AGE];
NSString * address = [rs stringForColumn:ADDRESS];
NSLog(@&id = %d, name = %@, age = %@
address = %@&, Id, name, age, address);
[db close];
数据库多线程操作： FMDatabaseQueue * queue = [FMDatabaseQueue databaseQueueWithPath:database_path];
dispatch_queue_t q1 = dispatch_queue_create(&queue1&, NULL);
dispatch_queue_t q2 = dispatch_queue_create(&queue2&, NULL);
dispatch_async(q1, ^{
for (int i = 0; i & 50; ++i) {
[queue inDatabase:^(FMDatabase *db2) {
NSString *insertSql1= [NSString stringWithFormat:
@&INSERT INTO '%@' ('%@', '%@', '%@') VALUES (?, ?, ?)&,
TABLENAME, NAME, AGE, ADDRESS];
NSString * name = [NSString stringWithFormat:@&jack %d&, i];
NSString * age = [NSString stringWithFormat:@&%d&, 10+i];
BOOL res = [db2 executeUpdate:insertSql1, name, age,@&济南&];
if (!res) {
NSLog(@&error to inster data: %@&, name);
NSLog(@&succ to inster data: %@&, name);
dispatch_async(q2, ^{
for (int i = 0; i & 50; ++i) {
[queue inDatabase:^(FMDatabase *db2) {
NSString *insertSql2= [NSString stringWithFormat:
@&INSERT INTO '%@' ('%@', '%@', '%@') VALUES (?, ?, ?)&,
TABLENAME, NAME, AGE, ADDRESS];
NSString * name = [NSString stringWithFormat:@&lilei %d&, i];
NSString * age = [NSString stringWithFormat:@&%d&, 10+i];
BOOL res = [db2 executeUpdate:insertSql2, name, age,@&北京&];
if (!res) {
NSLog(@&error to inster data: %@&, name);
NSLog(@&succ to inster data: %@&, name);
/*** @author 张兴业* &* &iOS入门群：* &android开发进阶群：* &我的新浪微博：* &我的邮箱：（#-&@）*//ccgus/fmdb
参考知识库
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：4689219次
积分：37671
积分：37671
排名：第77名
原创：274篇
转载：195篇
译文：20篇
评论：1862条
android 开发交流
济南移动互联网：
文章：10篇
阅读：369648
文章：18篇
阅读：520545
阅读：101423
文章：11篇
阅读：129362
文章：13篇
阅读：241604
文章：59篇
阅读：1501644
(1)(1)(2)(2)(1)(2)(4)(2)(3)(1)(2)(6)(1)(6)(5)(11)(3)(1)(7)(7)(7)(4)(5)(1)(1)(5)(1)(10)(11)(7)(5)(1)(2)(1)(8)(4)(4)(8)(23)(23)(1)(1)(1)(3)(9)(15)(34)(11)(5)(3)(3)(1)(5)(2)(5)(14)(23)(22)(25)(46)(7)(9)(30)(8)(1)(5)(1)Python 基础教程
python操作mysql数据库
Python 标准数据库接口为 Python DB-API，Python DB-API为开发人员提供了数据库应用编程接口。
Python 数据库接口支持非常多的数据库，你可以选择适合你项目的数据库：
PostgreSQL
Microsoft SQL Server 2000
你可以访问查看详细的支持数据库列表。
不同的数据库你需要下载不同的DB API模块，例如你需要访问Oracle数据库和Mysql数据，你需要下载Oracle和MySQL数据库模块。
DB-API 是一个规范. 它定义了一系列必须的对象和数据库存取方式, 以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口 。
Python的DB-API，为大多数的数据库实现了接口，使用它连接各数据库后，就可以用相同的方式操作各数据库。
Python DB-API使用流程：
引入 API 模块。
获取与数据库的连接。
执行SQL语句和存储过程。
关闭数据库连接。
什么是MySQLdb?
MySQLdb 是用于Python链接Mysql数据库的接口，它实现了 Python 数据库 API 规范 V2.0，基于 MySQL C API 上建立的。
如何安装MySQLdb?
为了用DB-API编写MySQL脚本，必须确保已经安装了MySQL。复制以下代码，并执行：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
如果执行后的输出结果如下所示，意味着你没有安装 MySQLdb 模块：
Traceback (most recent call last):
File "test.py", line 3, in &module&
import MySQLdb
ImportError: No module named MySQLdb
安装MySQLdb，请访问
，(Linux平台可以访问：)从这里可选择适合您的平台的安装包，分为预编译的二进制文件和源代码安装包。如果您选择二进制文件发行版本的话，安装过程基本安装提示即可完成。如果从源代码进行安装的话，则需要切换到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权限来安装上述模块。
数据库连接
连接数据库前，请先确认以下事项：
您已经创建了数据库 TESTDB.
在TESTDB数据库中您已经创建了表 EMPLOYEE
EMPLOYEE表字段为 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
连接数据库TESTDB使用的用户名为 "testuser" ，密码为 "test123",你可以可以自己设定或者直接使用root用户名及其密码，Mysql数据库用户授权请使用Grant命令。
在你的机子上已经安装了 Python
MySQLdb 模块。
如果您对sql语句不熟悉，可以访问我们的
以下实例链接Mysql的TESTDB数据库：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()
print "Database version : %s " % data
# 关闭数据库连接
db.close()
执行以上脚本输出结果如下：
Database version : 5.0.45
创建数据库表
如果数据库连接存在我们可以使用execute()方法来为数据库创建表，如下所示创建表EMPLOYEE：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 创建数据表SQL语句
sql = """CREATE TABLE EMPLOYEE (
FIRST_NAME
CHAR(20) NOT NULL,
SEX CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql)
# 关闭数据库连接
db.close()
数据库插入操作
以下实例使用执行 SQL INSERT 语句向表 EMPLOYEE 插入记录：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
# 执行sql语句
cursor.execute(sql)
# 提交到数据库执行
db.commit()
# Rollback in case there is any error
db.rollback()
# 关闭数据库连接
db.close()
以上例子也可以写成如下形式：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
LAST_NAME, AGE, SEX, INCOME) \
VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
('Mac', 'Mohan', 20, 'M', 2000)
# 执行sql语句
cursor.execute(sql)
# 提交到数据库执行
db.commit()
# 发生错误时回滚
db.rollback()
# 关闭数据库连接
db.close()
以下代码使用变量向SQL语句中传递参数:
..................................
user_id = "test123"
password = "password"
con.execute('insert into Login values("%s", "%s")' % \
(user_id, password))
..................................
数据库查询操作
Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。
fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall():接收全部的返回结果行.
rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。
查询EMPLOYEE表中salary（工资）字段大于1000的所有数据：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
WHERE INCOME & '%d'" % (1000)
# 执行SQL语句
cursor.execute(sql)
# 获取所有记录列表
results = cursor.fetchall()
for row in results:
fname = row[0]
lname = row[1]
age = row[2]
sex = row[3]
income = row[4]
# 打印结果
print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
(fname, lname, age, sex, income )
print "Error: unable to fecth data"
# 关闭数据库连接
db.close()
以上脚本执行结果如下：
fname=Mac, lname=Mohan, age=20, sex=M, income=2000
数据库更新操作
更新操作用于更新数据表的的数据，以下实例将 TESTDB表中的 SEX 字段全部修改为 'M'，AGE 字段递增1：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
WHERE SEX = '%c'" % ('M')
# 执行SQL语句
cursor.execute(sql)
# 提交到数据库执行
db.commit()
# 发生错误时回滚
db.rollback()
# 关闭数据库连接
db.close()
删除操作用于删除数据表中的数据，以下实例演示了删除数据表 EMPLOYEE 中 AGE 大于 20 的所有数据：
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE & '%d'" % (20)
# 执行SQL语句
cursor.execute(sql)
# 提交修改
db.commit()
# 发生错误时回滚
db.rollback()
# 关闭连接
db.close()
事务机制可以确保数据一致性。
事务应该具有4个属性：原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。
原子性（atomicity）。一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。
一致性（consistency）。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
隔离性（isolation）。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。
持久性（durability）。持续性也称永久性（permanence），指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。
Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。
# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE & '%d'" % (20)
# 执行SQL语句
cursor.execute(sql)
# 向数据库提交
db.commit()
# 发生错误时回滚
db.rollback()
对于支持事务的数据库， 在Python数据库编程中，当游标建立之时，就自动开始了一个隐形的数据库事务。
commit()方法游标的所有更新操作，rollback（）方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。
DB API中定义了一些数据库操作的错误及异常，下表列出了这些错误和异常:
Warning当有严重警告时触发，例如插入数据是被截断等等。必须是 StandardError 的子类。
Error警告以外所有其他错误类。必须是 StandardError 的子类。
InterfaceError当有数据库接口模块本身的错误（而不是数据库的错误）发生时触发。 必须是Error的子类。
DatabaseError和数据库有关的错误发生时触发。 必须是Error的子类。
DataError当有数据处理时的错误发生时触发，例如：除零错误，数据超范围等等。
必须是DatabaseError的子类。
OperationalError指非用户控制的，而是操作数据库时发生的错误。例如：连接意外断开、
数据库名未找到、事务处理失败、内存分配错误等等操作数据库是发生的错误。
必须是DatabaseError的子类。
IntegrityError完整性相关的错误，例如外键检查失败等。必须是DatabaseError子类。
InternalError
数据库的内部错误，例如游标（cursor）失效了、事务同步失败等等。
必须是DatabaseError子类。
ProgrammingError程序错误，例如数据表（table）没找到或已存在、SQL语句语法错误、
参数数量错误等等。必须是DatabaseError的子类。
NotSupportedError不支持错误，指使用了数据库不支持的函数或API等。例如在连接对象上
使用.rollback()函数，然而数据库并不支持事务或者事务已关闭。
必须是DatabaseError的子类。

我要回帖

更多关于 db数据库编辑器 的文章

 

随机推荐