|
本帖最后由 Aha 于 2014-12-13 14:37 编辑
- </blockquote></div><div class="blockcode"><blockquote>import traceback
- import sqlite3
- ## 数据库连接
- def connSql():
- try:
- ## 数据库文件test.db,若不存在则会在当前目录下创建
- conn = sqlite3.connect('test.db')
- ## 创建一个游标Cursor,用于数据库操作
- cursor = conn.cursor()
- except:
- ## 输出当前异常信息
- print traceback.format_exc()
- return conn, cursor
- def dosomething():
- conn, cursor = connSql()
- try:
- ## 创建表user,首先判断表是否存在
- sql = 'create table user( id varchar(20) primary key, name varchar(20))'
- cursor.execute(sql)
- ## 插入数据
- cursor.execute('insert into user (id, name) values ("1", "Aha")')
- cursor.execute('insert into user (id, name) values ("2", "Winstic")')
- except:
- pass
- ## 通过rowcount获得插入行数
- count = cursor.rowcount
- print 'insert %d rowcount' % count
- ## 关闭cursor
- cursor.close()
- ## 提交事务
- conn.commit()
- conn.close()
复制代码
在获取影响行数(count = cursor.rowcount)之前已经插入两行数据,但获取的值依然是1。。。。
|
|