SQLite數據庫使用單個磁盤文件,并且不需要像Oracle、MSSQL、MySQL等數據庫管理系統那樣啟動服務,使用非常靈活方便。但是SQLite也有個很嚴重的問題,就是沒有相應的服務,也沒有監聽任何端口,因此相應的程序只能訪問本地數據庫。也就是說,無法分離程序和數據庫,只能把程序和數據庫放在同一臺計算機上。
本文使用Python開發了一個SQLite數據庫的服務程序,可以完美地分離程序和數據庫。技術要點是Socket編程,在數據庫服務器上運行服務程序,該服務程序監聽特定端口、執行代理程序發來的SQL語句并返回結果;代理程序負責接收客戶端的SQL語句并轉發給服務器,然后再把服務器返回的結果轉發給客戶端。在具體使用時可以在本文代碼基礎上進行簡化和擴展。
服務程序:
### 服務器程序,接收代理服務器轉發來的SQL指令,并返回結果#import sqlite3import socketimport structdef getData(sql): '''通過給定的SQL SELECT語句返回結果''' with sqlite3.connect(r'database.db') as conn: cur = conn.cursor() cur.execute(sql) result = cur.fetchall() return resultdef doSql(sql): '''適用于DELETE/UPDATE/INSERT INTO語句,返回影響的記錄條數''' with sqlite3.connect(r'database.db') as conn: cur = conn.cursor() result = cur.execute(sql) return result.rowcount# 創建socket對象,默認使用IPV4+TCPsockServer = socket.socket()sockServer.bind(('', 3030))sockServer.listen(1)while True: # 接收客戶端連接 try: conn, addr = sockServer.accept() except: continue sql = conn.recv(1024).decode('gbk').lower() if sql.startswith(('update','delete','insert')): try: # 首先發送要發送的字節總數量 # 然后再發送真實數據 result = str(doSql(sql)).encode('gbk') conn.send(struct.pack('i', len(result))) conn.send(result) except: message = b'error' conn.send(struct.pack('i', len(message))) conn.send(message) elif sql.startswith('select'): try: result = str(getData(sql)).encode('gbk') conn.send(struct.pack('i', len(result))) conn.send(result) except: message = b'error' conn.send(struct.pack('i', len(message))) conn.send(message)代理程序:
### 代理服務器,在SQLite數據庫服務器和客戶端之間進行指令和數據的轉發# 這樣可以把數據庫和程序放到兩個服務器上進行分離##import socketfrom threading import Threadimport structsockServer = socket.socket()sockServer.bind(('',5050))sockServer.listen(50)def agent(conn): # 接收客戶端發來的指令,并進行過濾 sql = conn.recv(1024) if not sql.decode('gbk').startswith(('select', 'delete', 'insert','update')): message = b'not a sql statement' conn.send(struct.pack('i', len(message))) conn.send(message) return else: sockClient = socket.socket() # 嘗試連接服務器 try: sockClient.connect(('10.2.1.3', 3030)) except: message = b'Server not alive' conn.send(struct.pack('i', len(message))) conn.send(message) return # 向服務程序轉發SQL語句 sockClient.send(sql) # 數據量大小,使用sturct序列化一個整數需要4個字節 size = sockClient.recv(4) conn.send(size) size = struct.unpack('i', size)[0] while True: if size == 0: break elif size > 4096: data = sockClient.recv(4096) conn.send(data) size -= len(data) else: data = sockClient.recv(size) conn.send(data) size -= len(data) sockClient.close() conn.close()while True: conn, _ = sockServer.accept() Thread(target=agent, args=(conn,)).start()
新聞熱點
疑難解答