利用Python怎么實現一個SQLite代理服務器

這期內容當中小編將會給大家帶來有關利用Python怎么實現一個SQLite代理服務器，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

服務程序：

##
# 服務器程序，接收代理服務器轉發來的SQL指令，并返回結果
#
import sqlite3
import socket
import struct

def getData(sql):
 '''通過給定的SQL SELECT語句返回結果'''
 with sqlite3.connect(r'database.db') as conn:
  cur = conn.cursor()
  cur.execute(sql)
  result = cur.fetchall()
 return result

def 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+TCP
sockServer = 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 socket
from threading import Thread
import struct

sockServer = 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()

模擬客戶端程序：

##
# 模擬客戶端，向SQLite代理服務器發送指令并接收數據
#
import sqlite3
import socket
import struct

while True:
 sql = input('輸入一個要執行的SQL語句：\n')
 # 沒有輸入，進入下一次循環
 if sql.strip() == '':
  continue
 
 # 輸入exit或quit，退出客戶端
 if sql in ('exit', 'quit'):
  break
 # 建立socket，嘗試連接
 sockClient = socket.socket()
 try:
  sockClient.connect(('10.2.1.3', 5050))  
 except:
  print('服務器異常，請檢查')
 else:
  # 發送遠程SQL語句
  sockClient.send(sql.encode('gbk'))
  size = sockClient.recv(4)
  size = struct.unpack('i', size)[0]
  
  data = b''
  while True:
   if size == 0:
    break
   elif size > 4096:
    # 注意斷包和粘包
    # 雖然設置了4096，但是不一定能夠接收4096字節
    #即使緩沖區的數據遠多于4096
    t = sockClient.recv(4096)
    data += t
    size -= len(t)
   else:
    t = sockClient.recv(size)
    data += t
    size -= len(t)
  data = data.decode('gbk')
  try:
   data = eval(data)
  except:
   pass
  sockClient.close()
  print(data)

上述就是小編為大家分享的利用Python怎么實現一個SQLite代理服務器了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。