ในโค้ดต่อไปนี้ เรานำเข้าโมดูล sqlite3 และสร้างการเชื่อมต่อฐานข้อมูล เราสร้างตารางแล้วแทรกข้อมูลและดึงข้อมูลจากฐานข้อมูล sqlite3 และปิดการเชื่อมต่อในที่สุด
ตัวอย่าง
#sqlitedemo.py
import sqlite3
from employee import employee
conn = sqlite3.connect('employee.db')
c=conn.cursor()
c.execute(‘’’CREATE TABLE employee(first text, last text, pay integer)’’’)
emp_1 = employee('John', 'Doe', 50000 )
emp_2 = employee('Jane', 'Doe', 60000)
emp_3 = employee('James', 'Dell', 80000)
c.execute(‘’’INSERT INTO employee VALUES(:first, :last,
:pay)’’’,{'first':emp_1.first, 'last':emp_1.last,
'pay':emp_1.pay})
c.execute(‘’’INSERT INTO employee VALUES(:first, :last,
:pay)’’’,{'first':emp_2.first, 'last':emp_2.last,
'pay':emp_2.pay})
c.execute(‘’’INSERT INTO employee VALUES(:first, :last,
:pay)’’’,{'first':emp_3.first, 'last':emp_3.last,
'pay':emp_3.pay})
c.execute("SELECT * FROM employee WHERE last ='Doe'")
print(c.fetchone())
print(c.fetchmany(2))
conn.commit()
conn.close() ผลลัพธ์
(u'James', u'Dell', 80000) [(u'James', u'Dell', 80000), (u'James', u'Dell', 80000)]
