添加数据库编程.py

Author: heyxiaohao

.settings/org.eclipse.core.resources.prefs

@@ -7,6 +7,7 @@ encoding/\u5206\u5E03\u5F0F\u8FDB\u7A0B.py=utf-8
 encoding/\u591A\u7EBF\u7A0B.py=utf-8
 encoding/\u591A\u8FDB\u7A0B.py=utf-8
 encoding/\u5E8F\u5217\u5316.py=utf-8
+encoding/\u6570\u636E\u5E93\u7F16\u7A0B.py=utf-8
 encoding/\u6B63\u5219\u8868\u8FBE\u5F0F.py=utf-8
 encoding/\u9519\u8BEF_\u8C03\u8BD5\u548C\u6D4B\u8BD5.py=utf-8
 encoding/\u9762\u5411\u5BF9\u8C61.py=utf-8

数据库编程.py

@@ -0,0 +1,46 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+type = 'sqlite3'
+
+if type == 'sqlite3':
+    # 导入驱动
+    import sqlite3
+    # 连接到数据库 test.db 如果文件不存在，则会自动创建
+    conn = sqlite3.connect('test.db')
+    # 创建一个cursor
+    cursor = conn.cursor()
+    # 执行创建表
+    cursor.execute('create table user (id varchar(20) primary key, name varchar(20))')
+    # 执行插入数据
+    cursor.execute("insert into user (id, name) values ('1', 'wangh')")
+    # 通过rowcount获取影响的行数
+    print cursor.rowcount
+    # 关闭cursor
+    cursor.close()
+    # 提交事物
+    conn.commit()
+    # 关闭connection
+    conn.close()
+    
+    conn1 = sqlite3.connect('test.db')
+    cursor1 = conn1.cursor()
+    # 执行查询语句
+    cursor1.execute("select * from user where id=?", '1')
+    # 获取结果集
+    value = cursor1.fetchall()
+    print value
+    cursor1.close()
+    conn1.close()
+    
+    
+    
+    
+    
+    
+    
+    
+    
+    
+    
+