Lưu cơ sở dữ liệu sqlite python

Trong một bài viết trước mình đã hướng dẫn các bạn kết nối với SQLite 3 bằng cách sử dụng ngôn ngữ lập trình PHP. Ở bài viết này, mình sẽ hướng dẫn các bạn tiếp tục sử dụng ngôn ngữ Python để kết nối với SQLite một cách đơn giản nhất

Nội dung chính Show

Phương thức execmany()
LỰA CHỌN
Get phần tử thông qua tên cột
Truyền tham số vào câu hỏi

Đầu tiên chúng ta nhập thư viện sqlite3

import sqlite3

Bây giờ, hãy thực hiện kết nối đến db, và tạo con trỏ

# Connect to DB and create a cursor
sqliteConnection = sqlite3.connect('vinasupport.db')
cursor = sqliteConnection.cursor()
print('DB Init')

Chú ý, SQLite used a file to doing database

Sau khi khởi động, bạn đã có thể thực hiện các câu lệnh SQL

VD. Lấy phiên bản của SQLite

# Write a query and execute it with cursor
query = 'select sqlite_version();'
cursor.execute(query)

# Fetch and output result
result = cursor.fetchall()
print('SQLite Version is {}'.format(result))

In data and close con cursor

# Fetch and output result
result = cursor.fetchall()
print('SQLite Version is {}'.format(result))

# Close the cursor
cursor.close()

The same is close the connection to database

if sqliteConnection:
    sqliteConnection.close()
    print('SQLite Connection closed')

Cuối cùng, chúng ta có đoạn mã như sau

import sqlite3

try:
    # Connect to DB and create a cursor
    sqliteConnection = sqlite3.connect('sql.db')
    cursor = sqliteConnection.cursor()
    print('DB Init')

    # Write a query and execute it with cursor
    query = 'select sqlite_version();'
    cursor.execute(query)

    # Fetch and output result
    result = cursor.fetchall()
    print('SQLite Version is {}'.format(result))

    # Close the cursor
    cursor.close()

# Handle errors
except sqlite3.Error as error:
    print('Error occurred - ', error)

# Close DB Connection irrespective of success
# or failure
finally:

    if sqliteConnection:
        sqliteConnection.close()
        print('SQLite Connection closed')

Kết quả sau khi chạy

Chúng ta kết nối với cơ sở dữ liệu

import sqlite3 as lite

9 và thực hiện câu hỏi truy vấn lấy thông tin về phiên bản SQLite đang sử dụng

import sqlite3 as lite

Đầu tiên chúng ta mô-đun nhập khẩu

import sqlite3 as lite

con = None

Biến

con = None

2 là biến lưu trữ đối tượng

con = None

3 khi chúng tôi kết nối cơ sở dữ liệu

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

Để kết nối đến cơ sở dữ liệu, chúng ta sử dụng phương thức

con = None

4, phương thức này trả về một đối tượng

con = None

cur = con.cursor()    
cur.execute('SELECT SQLITE_VERSION()')

Sau khi đã có đối tượng

con = None

3, chúng ta lấy một đối tượng

con = None

7, đối tượng này làm nhiệm vụ duyệt qua các bản ghi trong tệp dữ liệu được lấy về và thực hiện các câu truy vấn. Để thực hiện một câu truy vấn, chúng ta sử dụng phương thức

con = None

data = cur.fetchone()

Phương thức

con = None

9 lấy về dòng đầu tiên của bảng dữ liệu trả về

print ("SQLite version: %s" % data)

We ta in data line that ra screen

finally:
    
    if con:
        con.close()

Sau khi đã hoàn tất công việc, chúng ta sẽ đóng kết nối tới CSDL theo phương thức

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Trong ví dụ dưới đây, chúng tôi cũng lấy phiên bản SQLite nhưng sử dụng từ khóa

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Sử dụng từ khóa

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

1 có tác dụng làm cho mã dễ dàng hơn và các câu lệnh SQL có liên quan đến việc cập nhật dữ liệu như INSERT, UPDATE, DELETE… sẽ tự động được thực thi (nếu không thì bạn phải gọi thêm phương thức

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Python sẽ tự động xử lý ngoại lệ và tự động ngắt kết nối cơ sở dữ liệu khi không sử dụng nữa nếu có từ khóa

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

CHÈN

Chúng ta sẽ thực hiện câu hỏi INSERT

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Đoạn mã trên bảng tạo

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

5 và chèn 8 dòng dữ liệu vào bảng này

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Bảng

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

5 sẽ có 3 cột là

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

8 và

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Chúng ta chỉ cần sử dụng phương thức

con = None

8 để thực hiện các câu lệnh SQL. Khi sử dụng từ khóa with, các câu lệnh này sẽ được thực hiện ngay trên cơ sở dữ liệu

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Các câu lệnh như CẬP NHẬT, XÓA… bạn cũng làm tương tự

Phương thức execmany()

Phương thức

cur = con.cursor()    
cur.execute('SELECT SQLITE_VERSION()')

1 tiện lợi hơn bằng cách thực hiện nhiều câu lệnh cùng một lúc

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Chúng ta xóa bảng và tạo lại bảng

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Đầu tiên chúng ta kiểm tra xem bảng

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

5 đã tồn tại chưa, nếu rồi thì xóa bảng đó và tạo lại bảng mới

C:\User\PhoCode>sqlite3 test.db
SQLite version 3.7.13 2012-06-11 02:05:22
Enter ".help" for instructions
Enter SQL statements terminated with a ";"

Chúng ta chèn 8 dòng dữ liệu vào bảng bằng một phương thức duy nhất là

cur = con.cursor()    
cur.execute('SELECT SQLITE_VERSION()')

1, tham số đầu tiên là một câu lệnh SQL có tham số là các dấu ?, tham số thứ 2 là một bộ chứa nhiều bộ dữ liệu khác nhau

LỰA CHỌN

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Chúng ta sẽ lấy các bản ghi từ bảng

path = os.path.dirname(__file__) + "\\test.db"
con = lite.connect(path)

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Việc làm này cũng rất đơn giản, chỉ cần sử dụng phương thức

con = None

8 với câu SQL tương ứng

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Phương thức

cur = con.cursor()    
cur.execute('SELECT SQLITE_VERSION()')

7 sẽ trả về một tuple chứa các tuple là các dòng dữ liệu trong bảng

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

We ta in the tuple that ra screen

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Bạn cũng có thể vào từng dòng một nếu muốn

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Chúng ta lấy từng dòng và trong màn hình của chúng ta

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Chúng ta sử dụng một vòng lặp để lặp qua từng dòng dữ liệu trong bảng. Vòng lặp kết thúc khi đối tượng

con = None

7 đã đọc hết dữ liệu trong bảng

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Đối tượng

con = None

7 có chứa một con trỏ chỉ đến các dòng trong bảng. Phương thức

con = None

9 sẽ đưa con trỏ này lên một dòng và trả về dữ liệu của dòng đó, nếu con trỏ chỉ qua dòng cuối cùng thì sẽ trả về một đối tượng

data = cur.fetchone()

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()

Dữ liệu trả về là một bộ dữ liệu nên bạn có thể truy xuất từng phần tử trong bộ dữ liệu bằng cặp dấu

data = cur.fetchone()

import sqlite3 as lite
import sys
import os
con = None

try:
    path = os.path.dirname(__file__) + "\\test.db"
    con = lite.connect(path)
    
    cur = con.cursor()    
    cur.execute('SELECT SQLITE_VERSION()')
    
    data = cur.fetchone()
    
    print ("SQLite version: %s" % data)         
    
except lite.Error as e:
    
    print ("Error %s:" % e.args[0])
    sys.exit(1)
    
finally:
    
    if con:
        con.close()