您的位置:首页 > 数据库

程序媛:数据库操作之封装为函数(sqlite3 )

2017-09-18 20:59 253 查看
# import sqlite3
#
# connect = sqlite3.connect("test.db") #创建数据库
# cursor = connect.cursor()              #创建游标,以便使用sql语句
# #创建一个名为diary的表,并设置一个id为自增主键,title、content 为text类型
# cursor.execute("drop table diary")
# cursor.execute("CREATE  TABLE diary(id INTEGER PRIMARY KEY AUTOINCREMENT,title TEXT,content TEXT)")
# #向表中插入数据,因为是自增主键,id可以写成NULL,表中id值会是1、2、3、、、递增
# cursor.execute("INSERT INTO diary(title,content) VALUES ('title2','content2')")
# #查询表中所有数据,并输出
# print('***********增***********')
# for row in cursor.execute("select * from diary"):
#     print(row)
#
# print('***********删***********')
# #修改id为2的数据
# cursor.execute("UPDATE diary SET title='title1',content='content000' WHERE id =2")
# #再输出所有数据,验证是否修改成功
# for row in cursor.execute("select * from diary"):
#     print(row)
# print('***************改****************')
# #一次插入多条数据
# items =[("title0","content000"),("title1","content1"),("title2","content2")]
# cursor.executemany("insert into diary(title,content) values (?,?)",items)
# print('插入多条数据后的表:')
# for row in cursor.execute("select * from diary"):
#     print(row)
# print('查询id为5的数据')
# cursor.execute("select * from diary where id=4")
# print(cursor.fetchall())
#
# print("查询title为title0的数据")
# cursor.execute("select * from diary where title='title0'")
# print(cursor.fetchall())

# import sqlite3
# con=sqlite3.connect("test.db")
# cur=con.cursor()
# cur.execute("select name from sqlite_master where type='table'")
# for row in cur.fetchall():
#     print(row)
#     print(row[0])

# import sqlite3
# conn=sqlite3.connect("test.db")
# cursor=conn.cursor()
# def searchTable(str):
#     global cursor
#     flag=False
#     cursor.execute("select name from sqlite_master where type='table'")
#     for item in cursor.fetchall():
#         if item[0]== str:
#             print('searchTable:', item[0])
#             flag=True
#             break
#     return flag
#
# def initTable(str):
#     global cursor
#     if searchTable(str)==False:
#         cursor.execute("create table",str,"(id INTEGER PRIMARY KEY AUTOINCREAMENT,tile TEXT,content TEXT)")
#     else:
#         print("该表已存在")
#
# initTable("diary")
# initTable("diary")

import sqlite3
con=sqlite3.connect("test.db")
cursor=con.cursor()

#插入数据,参数分别为表名(字符串类型)、数据(元组类型)
def insertData(name,tup):
global  con
global cursor
sql = "insert into "+ name+ "(title,content) values (?,?)"
cursor.execute(sql,tup)
con.commit()
#根据id删除数据,参数分别为表名,主键(整型)
def deleteData(name,id):
global con
global cursor
sql="delete from "+name+" where id="+str(id)
cursor.execute(sql)
con.commit()
#根据id修改数据,参数分别为表名(字符串类型)主键(整型)、数据(元组)
def updateData(name,id,tup):
global con
global cursor
sql="update "+name+" set title="+tup[0]+"content="+tup[1]
cursor.execute(sql)
con.commit()
#根据id查找数据,参数分别为表名,主键
def searchData(name):
global cursor
sql="select * from "+name
cursor.execute(sql)
for row in cursor.fetchall():
print(row)

insertData("diary",("title10","content10"))
searchData("diary")
deleteData("diary",2)
searchData("diary")
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  python