Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import sqlite3
- def connect_db():
- db = sqlite3.connect("demodb.db")
- print("Database connected")
- return db
- def create_table(db):
- cursor = db.cursor()
- cursor.execute("create table if not exists users(id integer primary key,name text,age integer)")
- print("Table created")
- db.commit()
- def insert_data(db,id,name,age):
- cursor = db.cursor()
- cursor.execute("insert into users(id,name,age) values(?,?,?)",(id,name,age))
- print("\nData inserted into table")
- db.commit()
- def fetch_data(db):
- cursor = db.cursor()
- cursor.execute("select * from users")
- rows = cursor.fetchall()
- print("Fetching...")
- for i in rows:
- print(i)
- db.commit()
- def update_data(db,id,age):
- cursor = db.cursor()
- cursor.execute("update users set age=? where id=?",(age,id))
- print("\nTable updated")
- db.commit()
- def delete_data(db,id):
- cursor = db.cursor()
- cursor.execute("delete from users where id=?",(id,))
- print("\nData deleted")
- db.commit()
- if __name__=="__main__":
- db = connect_db()
- create_table(db)
- insert_data(db,1,"Talha",19)
- insert_data(db,2,"Oubed",16)
- fetch_data(db)
- update_data(db,2,17)
- fetch_data(db)
- delete_data(db,2)
- fetch_data(db)
- db.close()
- print("Database disconnected")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement