使用Python开发SQLite代理服务器的方法
作者:shaomine 时间:2021-01-27 13:10:31
SQLite数据库使用单个磁盘文件,并且不需要像Oracle、MSSQL、MySQL等数据库管理系统那样启动服务,使用非常灵活方便。但是SQLite也有个很严重的问题,就是没有相应的服务,也没有监听任何端口,因此相应的程序只能访问本地数据库。也就是说,无法分离程序和数据库,只能把程序和数据库放在同一台计算机上。
本文使用Python开发了一个SQLite数据库的服务程序,可以完美地分离程序和数据库。技术要点是Socket编程,在数据库服务器上运行服务程序,该服务程序监听特定端口、执行代理程序发来的SQL语句并返回结果;代理程序负责接收客户端的SQL语句并转发给服务器,然后再把服务器返回的结果转发给客户端。在具体使用时可以在本文代码基础上进行简化和扩展。
服务程序:
##
# 服务器程序,接收代理服务器转发来的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)
来源:https://www.cnblogs.com/shaosks/p/7084040.html
标签:Python,SQLite
0
投稿
猜你喜欢
pyx文件 生成pyd 文件用于 cython调用的实现
2022-09-17 13:54:32
Python中的zip函数使用示例
2021-05-15 01:10:53
Python3将jpg转为pdf文件的方法示例
2021-06-25 11:31:17
opencv实现答题卡识别
2021-02-28 12:40:05
Python JSON格式数据的提取和保存的实现
2023-03-23 13:27:49
Docker创建Mysql容器的简单步骤
2024-01-28 20:20:40
python获取网络图片方法及整理过程详解
2022-10-21 19:33:20
在oracle 数据库查询的select 查询字段中关联其他表的方法
2009-08-31 12:27:00
漫谈前端开发中的团队合作
2009-02-05 21:02:00
得到字符串真实长度和取固定长度的字符串函数
2008-10-06 13:12:00
自定义404错误页面实现自动跳转
2007-12-10 18:25:00
Python实现的大数据分析操作系统日志功能示例
2022-07-31 00:40:34
python创建文件时去掉非法字符的方法
2023-10-12 02:15:51
Python中的数学运算操作符使用进阶
2021-05-24 16:05:46
解读JavaScript代码 var ie = !-[1,] 最短的IE判定代码
2011-06-06 10:29:00
基于Python实现股票收益率分析
2022-03-15 20:24:08
完美兼容各大浏览器获取HTTP_REFERER方法总结
2024-04-22 13:04:24
讲解Python中运算符使用时的优先级
2022-12-28 14:40:17
如何从Notes中读取数据?
2009-11-15 19:57:00
python去除文件中重复的行实例
2022-07-30 17:33:38