国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

使用Python開發SQLite代理服務器的方法

2020-02-15 23:59:55
字體:
來源:轉載
供稿:網友

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()            
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 同心县| 军事| 大安市| 广德县| 冕宁县| 万宁市| 比如县| 东源县| 韶山市| 红桥区| 儋州市| 洪湖市| 宿松县| 抚顺市| 滦南县| 华安县| 高淳县| 江安县| 耒阳市| 崇礼县| 互助| 景德镇市| 徐州市| 东乌珠穆沁旗| 白朗县| 南通市| 昌图县| 枣庄市| 安图县| 齐河县| 澄江县| 高唐县| 福鼎市| 涞水县| 庄浪县| 安溪县| 江阴市| 建平县| 莒南县| 陵川县| 凭祥市|