使用Python开发SQLite代理服务器
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)
--------------我是分割线-------------
“Python小屋”公众号近期主要活动:
1、赠书活动:详情请进入公众号以后通过菜单“最新资源”===>“历史文章分类表”进行查看
2、Python师资培训班:8月6日-12日,济南,面向全国高校老师和企业朋友,通知详见关于举办2017年暑期全国高校教师 “Python编程及应用”培训班通知
使用Python开发SQLite代理服务器相关推荐
- python能做数据库开发吗_5分钟快速入门,用Python做SQLite数据库开发,附代码适合初学...
1. 它是内置的,不需要安装,节省很多麻烦.2. 使用方便,不需要复杂的连接配置,打开本地文件一样简单.3.方便转移.数据库是一个文件.复制.传输和删除可以很容易地处理.4所示.轻量级的性能比大多数其 ...
- python开发系列
python基础教程 python基础系列教程--Python的安装与测试:python解释器.PyDev编辑器.pycharm编译器 python基础系列教程--Python库的安装与卸载 pyth ...
- 【转】python开发大全、系列文章、精品教程
版权声明:本文为博主原创文章,转载请注明来源.开发合作联系luanpenguestc@sina.com https://blog.csdn.net/luanpeng825485697/article/ ...
- python开发大全、系列文章、精品教程
全栈工程师开发手册 (作者:栾鹏) python教程全解 python基础教程 python基础系列教程--Python的安装与测试:python解释器.PyDev编辑器.pycharm编译器 pyt ...
- 为什么 Django 能持续统治 Python 开发世界
2019独角兽企业重金招聘Python工程师标准>>> 对于 Python 开发者来说,web 开发框架真可谓玲琅满目.然而 Django , 毋庸置疑的成为最受青睐的 web 框架 ...
- python开发安卓程序-如何使用python开发android应用
Python是一种面向对象.解释型计算机程序设计语言,其源代码和解释器CPython遵循GPL(GNU General Public License)协议Python语法简洁清晰,特色之一是强制用空白 ...
- python开发安卓程序-如何使用python开发Android手机应用?
在使用python开发android应用之前我们需要准备好环境,环境需要安装PythonForAndroid,然后开始编程,编程时打开eclipse, 创建一个新的android project &q ...
- python开发安卓程序-用python开发android应用(1)
Python是动态语言,比较简洁.Android不直接支持使用python开发应用,需要使用其它中间件或者库.PythonForAndroid提供了在android平台上对python语言的支持:CL ...
- 用python实现todolist_So easy !用 Python 开发一个todolist
原标题:So easy !用 Python 开发一个todolist 有一句话是这样说的:"凡事预则立,不预则废",说的是我们在做事之前,最好制定好你的计划,然后有序的去执行,这样 ...
最新文章
- 幸运数字Ⅱ(树型结构构造答案,打表)难度⭐⭐
- R语言使用caretEnsemble包的caretStack函数把多个机器学习模型融合成一个模型、构建融合(集成)预测模型、使用融合模型进行预测推理
- 虚拟机ping不通开发板如何解决
- 笔记本用无线路由器上网设置教程攻略
- 关于select中fd_set变量的一些通俗宏解释
- delphi image 编辑器_照片拼图编辑器app下载-照片拼图编辑器下载 v1.0.0 安卓版
- JZOJ 3055. 【NOIP2012模拟10.27】比赛
- android手机网络Ping测试
- pandas学习之变形
- JVM、DVM(Dalvik VM)和ART虚拟机的区别
- 云防护当道,如何绕过云防护来进行渗透测试
- 2021-10-11
- 用python爬小说_今天分享一个用Python来爬取小说的小脚本!(附源码)
- php防刷红包,PHP防止多次请求刷红包的方法
- 免费开放NBA赛事接口
- linux环境下运行flex,什么是flex?
- SDOI2014 Round1 day2
- DevOps到底是什么意思?-小白收藏
- 服务器安全部署文档(转载)
- Android Studio代理
热门文章
- java post raw_Java raw 请求和获取
- linux svn启动失败,linux svn authorization failed错误
- c开头英文语言,C开头的考研英语词汇
- python kivy canvas_python – Kivy:使用canvas为动画设置动画的正确方法是什么?
- python中numpy的用法_Python中numpy多维数组的用法
- 4 转推流格式_ppt 转 pdf怎么转?这个宝藏技巧不会太亏了!
- linux nginx django,如何在Linux下使用Nginx部署Django项目
- 玩转 Springboot 2 之热部署(DevTools)
- Job 存储和持久化 (第一部分)
- FusionCharts破解版导出图片步骤