devbox
我家小花儿
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

简单云数据库API开发

作者：我家小花儿 | 2024-07-27 09:17:24

赞

踩

简单云数据库API开发

目录

步骤一：项目目录

各位客官，让我们首先上个目录，让大家有个大体了解。

步骤二：材料准备

本次用到的一些python库：

本次用到的一些知识：

代码（注释详细，小白可入！）

接下来把代码放一下，注释写的很详细也都是基础知识。

再之后是SDK与文档，这两个接口这么能缺呢？

步骤一：项目目录

各位客官，让我们首先上个目录，让大家有个大体了解。

  1. cloudDatabase项目文件夹
  2. │  main.py        主应用入口
  3. │  operation.py        定义一些常用操作函数
  4. │
  5. ├─database        db数据库文件存放文件夹
  6. │      databaseInformation.db
  7. │      user.db
  8. │
  9. ├─databaseManagement        管理db数据库的py程序
  10. │  │  databaseInformation.py
  11. │  │  user.py
  12. │  │  __init__.py
  13. │  │
  14. │  └─__pycache__
  15. │          databaseInformation.cpython-37.pyc
  16. │          user.cpython-37.pyc
  17. │          __init__.cpython-37.pyc
  18. │
  19. ├─pythonSdk        面向Python的SDK代码目录
  20. │      main.py
  21. │      __init__.py
  22. │
  23. ├─static        Flask固定资源存放文件夹
  24. │      cloudDatabase.jpg
  25. │      top.png
  26. │
  27. └─templates        Flask网页模板存放文件夹
  28.         index.html

步骤二：材料准备

本次用到的一些python库：

主要是sqlite3，flask（具体是Flask,request）
json,time,os等等常用库就不说了。

本次用到的一些知识：

flask：

  1. from flask import Flask,request,render_template
  2.  
  3. app = Flask(__name__)
  4. app.debug = True
  5.  
  6. @app.route('/init',methods=['POST'])
  7. def init(): # 接口初始化
  8.     userId = data['userId'] # 获取userId
  9.     ip = data['ip'] # 获取ip
  10.  
  11. app.run(host="0.0.0.0",port=5000)

解释：

app = Flask(__name__) ：

web服务器使用wsgi协议，把客户端所有的请求都转发给这个程序实例
初始化：所有的Flask都必须创建程序实例， 程序实例是Flask的对象，一般情况下用如下方法实例化 Flask类只有一个必须指定的参数，即程序主模块或者包的名字，__name__是系统变量，该变量指的是本py文件的文件名

app.debug = True：开启调试，只要更改源代码文件就会自动加载，不需要一直手动运行

@app.route('/init',methods=['POST'])
def init(): # 接口初始化

在flask中，定义路由最简便的方式，是使用程序实例的app.route装饰器，把装饰的函数注册为路由

userId = data['userId'] # 获取userId
ip = data['ip'] # 获取ip

这是获取post传参的方法

app.run(host="0.0.0.0",port=5000)

run方法启动flask集成的开发web服务器

服务器启动后，会启动轮询，等待并处理请求。轮询会一直请求，直到程序停止。

host="0.0.0.0"不填会自动加载本机ip但我们需要外网可访问所以填"0.0.0.0"会自动加载外网地址

port=5000表示监听5000端口，可以设置其他的，不过为了我吗能够顺利打开，在服务器上也要添加对应端口，这里方法我们文章后续讲解

SQLite3

  1. conn = sqlite3.connect(dbPath) # 连接数据库
  2. c = self.conn.cursor() # 新建游标
  3. sql = '''select ip from userToken'''  # 查询 userToken 的 ip 列
  4. results = self.c.execute(sql)  # 获取结果
  5. # 数据库将返回结果到results变量中
  6. all_ip = results.fetchall()

学习：
 sql = '''select */column from tablename'''
 "*"代表所有内容。此代码我们搜寻“students”表的所有内容。
  sql = '''select */column from userToken where column="string"'''
  sql语句意为从表格中挑选 符合Boolean语句为真的条件 的 全部内容或某些列项 。
  如果只是想看students表的id列，eg：select id from students 

因为返回的results类似于：<sqlite3.Cursor object at 0x00000257F9100AB0>是sqlite3对象
所以需要使用fetchall函数把所有结果保存到新的变量中，也就是用fetchall（）方法获取查询结果
值如下[('286.56.2',), ('5255324532',)]整体为列表在，其中每个元组值代表数据库表中的一行数据，元组中每个值则为这行数据的某列值

简单sql语句
"INSERT INTO userToken values(?,?,?,?)" 
# 添加值 其中userToken为表名 values（）传参每个?(英文）是占位符代表一个值，一行数据需要几个值就写几个问号。官网提倡这样传参说用python字符串拼接不安全
"UPDATE userToken SET time=? WHERE ip=?" 
# 更新值where ip= 是要验证的条件，整体说就是当一行数据满足ip= 设定值时把这行对应的time值设置成某某
'''create table if not exists 测试用表(roollno real,name text,class real)''' 
# 创建表 create table if not exists意思是如果这个表不存在则创建能避免出错。

还有执行语句：

c.execute(sql, (ip,token, ts,power))  # 执行sql语句 sql就是上面的sql语句是字符串，后面（）是传入sql语句中?所代表的参数，注意需要一个元组，只有一个参数ip时要写成（ip,）","不能丢不然不是元组

有了这点基础知识，对sql这块不了解也没关系，网上很多可视化软件，这里我推荐Navicat 15 for SQLite，其他的也行，这不是主要的。

最后我还想说的是，本文用到的一个创建随机字符串的方法：

  1. def creatToken(self):
  2.       """
  3.       生成一个指定长度的随机字符串，充当token
  4.       """
  5.       randomlength = 36 # 定义字符串长度
  6.  
  7.       random_str =''
  8.       base_str ='@#$%^&*()_+|=-!~`.,?:;ABCDEFGHIGKLMNOPQRSTUVWXYZabcdefghigklmnopqrstuvwxyz0123456789'
  9.       length =len(base_str) -1
  10.       for i in range(randomlength):
  11.         random_str +=base_str[random.randint(0, length)]
  12.  
  13.       return random_str

 不难理解random.randint创建随机数在base_str中的字符中不断随机挑选字符，组成我们需要的随机字符串。

代码（注释详细，小白可入！）

接下来把代码放一下，注释写的很详细也都是基础知识。

  1. # -*- coding: utf-8 -*-
  2. """
  3. @connect： 云数据库
  4. @Time ： 2022/7/17-2022/7/18
  5. @python ： python3.7 ， flask
  6. @File ：main.py
  7. @IDE ：PyCharm
  8. @Motto：技术总是要日积月累的
  10. """
  11. '''
  12. 目录介绍：
  13. cloudDatabase项目文件夹
  14. │  main.py        主应用入口
  15. │  operation.py        定义一些常用操作函数
  16. │
  17. ├─database        db数据库文件存放文件夹
  18. │      databaseInformation.db
  19. │      user.db
  20. │
  21. ├─databaseManagement        管理db数据库的py程序
  22. │  │  databaseInformation.py
  23. │  │  user.py
  24. │  │  __init__.py
  25. │  │
  26. │  └─__pycache__
  27. │          databaseInformation.cpython-37.pyc
  28. │          user.cpython-37.pyc
  29. │          __init__.cpython-37.pyc
  30. │
  31. ├─pythonSdk        面向Python的SDK代码目录
  32. │      main.py
  33. │      __init__.py
  34. │
  35. ├─static        Flask固定资源存放文件夹
  36. │      cloudDatabase.jpg
  37. │      top.png
  38. │
  39. └─templates        Flask网页模板存放文件夹
  40.         index.html
  41. '''
  42. import sqlite3
  43. import traceback
  44. import json,time,os
  45. from flask import Flask,request,render_template
  46. from databaseManagement.user import user
  47. from databaseManagement.databaseInformation import databaseInformation
  48. from  operation import operation
  49.  
  50. app = Flask(__name__)
  51. app.debug = True
  52.  
  53. operation = operation(app.debug) # 初始化operation，获取常用操作支持以及设定常量
  54.  
  55. # 正确配置测试
  56. @app.route('/',methods=['GET'])
  57. def test():
  58.     return render_template('index.html')
  59.  
  60. # 接口初始化
  61. @app.route('/init',methods=['POST'])
  62. def init(): # 接口初始化
  63.     headers =request.headers # 获得headers
  64.  
  65.     # post参数处理，储存到data（字典）
  66.     data = operation.dealPostData(request.data)
  67.  
  68.     userId = data['userId'] # 获取userId
  69.     ip = data['ip'] # 获取ip
  70.     # 根据账户判断权限
  71.     if userId == operation.adminAccount:
  72.         power = 0
  73.     elif userId == '':
  74.         power = 3
  75.  
  76.     userManagenmant = user() # 实例化user
  77.     ipList = userManagenmant.get_ipList()
  78.     tokenList = userManagenmant.get_tokenList()
  79.  
  80.     # 检测ip是否已经存在
  81.     if ip in ipList:
  82.         token = userManagenmant.searchToken(ip)
  83.         results = userManagenmant.updateTime(ip)
  84.         print('result',results)
  85.     else:
  86.         token = userManagenmant.creatToken()
  87.         while token in tokenList:
  88.             token = userManagenmant.creatToken()
  89.         results = userManagenmant.addToken(ip, token,power)
  90.  
  91.     userManagenmant.close()
  92.  
  93.     if results:
  94.         returnData = {"token":token,"time":time.time()}
  95.         return operation.dealReturn(code = 200,returnData = returnData ,reason = '合法请求，请求成功。',tips = None)
  96.     else:
  97.         resultJson = '''{"result"："失败！"}'''
  98.         return operation.dealReturn(code = 500,returnData = None ,reason = '服务器发生未知错误',tips = '重新尝试操作或联系管理员。')
  99.  
  100.  
  101. # 查询数据库信息
  102. @app.route('/information',methods=['POST'])
  103. def information(): # 查询数据库信息
  104.     headers = request.headers  # 获得headers
  105.  
  106.     # post参数处理，储存到data（字典）
  107.     data = operation.dealPostData(request.data)
  108.  
  109.     token = data['token']  # 获取token
  110.  
  111.     userManagenmant = user()  # 实例化user
  112.  
  113.     # 查询权限并检查账户
  114.     power = userManagenmant.searchPower(token)
  115.     if power == None:
  116.         return operation.dealReturn(code=401, returnData=None, reason='不合法的账户，token失效或不存在。', tips='请检查token或重新获取token')
  117.  
  118.     if power == 0:
  119.         try:
  120.             dbManagenmant = databaseInformation()  # 实例化databaseInformation
  121.             dbNameList = dbManagenmant.get_databaseName()
  122.  
  123.             # 获取数据库文件大小
  124.             availableMemory = 0
  125.             for fileName in dbNameList:
  126.                 name = fileName + ".db"
  127.                 size = os.path.getsize(operation.databasePath+name)
  128.                 availableMemory = availableMemory + size
  129.  
  130.             returnData ={
  131.                         "databaseName":dbNameList,
  132.                         "totalMemory":operation.totalMemory,
  133.                         "availableMemory":availableMemory,
  134.             }
  135.  
  136.             dbManagenmant.close() # 关闭数据库
  137.             return operation.dealReturn(code=200, returnData=returnData, reason='合法请求，请求成功。', tips=None)
  138.         except Exception as e:
  139.             return operation.dealErro(code=500, returnData=None, reason='发生内部错误。错误信息（erro）：'+e, tips='重新尝试操作或联系管理员。')
  140.     else:
  141.         return operation.dealReturn(code=401, returnData=None, reason='不合法的账户，token无权限执行此操作。', tips='请以管理员身份操作。')
  142.  
  143. # 添加数据库
  144. @app.route('/addDatabase',methods=['POST'])
  145. def addDatabase():# 添加数据库
  146.     headers = request.headers  # 获得headers
  147.  
  148.     # post参数处理，储存到data（字典）
  149.     data = operation.dealPostData(request.data)
  150.  
  151.     token = data['token']  # 获取token
  152.     databaseName = data['databaseName'] # 获取databaseName
  153.     # databaseName中.db后缀处理
  154.     if '.db' in databaseName:
  155.         databaseName = databaseName.replace('.db','')
  156.  
  157.     userManagenmant = user()  # 实例化user
  158.     dbManagenmant = databaseInformation()  # 实例化databaseInformation
  159.  
  160.     # 查询权限并检查账户
  161.     power = userManagenmant.searchPower(token)
  162.     if power == None:
  163.         return operation.dealReturn(code=401, returnData=None, reason='不合法的账户，token失效或不存在。', tips='请检查token或重新获取token')
  164.  
  165.     # 权限合格处理请求
  166.     if power == 0:
  167.         try:
  168.             result = dbManagenmant.addDatabase(databaseName,operation.databasePath+databaseName+'.db')
  169.             if result == '已存在':
  170.                 return operation.dealReturn(code=400, returnData=None, reason='该数据库已经存在。', tips='请直接使用或更换其他未使用的名称。')
  171.             elif result:
  172.                 returnData = {
  173.                     "result": "success",
  174.                     "databaseName": databaseName,
  175.                     "time":time.time()
  176.                 }
  177.  
  178.                 userManagenmant.close()
  179.                 dbManagenmant.close()
  180.                 return operation.dealReturn(code=200, returnData=returnData, reason='合法请求，请求成功。', tips=None)
  181.             else:
  182.                 userManagenmant.close()
  183.                 dbManagenmant.close()
  184.                 return operation.dealErro(code=500, returnData=None, reason='发生内部错误。错误信息（erro）：', tips='重新尝试操作或联系管理员。')
  185.         except Exception as e:
  186.             userManagenmant.close()
  187.             dbManagenmant.close()
  188.             return operation.dealErro(code=500, returnData=None, reason='发生内部错误。错误信息（erro）：'+e, tips='重新尝试操作或联系管理员。')
  189.  
  190.     else:
  191.         userManagenmant.close()
  192.         dbManagenmant.close()
  193.         return operation.dealReturn(code=401, returnData=None, reason='不合法的账户，token无权限执行此操作。', tips='请以管理员身份操作。')
  194.  
  195.  
  196. # 执行一条非查询的sql语句
  197. @app.route('/notQuerySqlExecute',methods=['POST'])
  198. def notQuerySqlExecute():# 执行一条非查询的sql语句
  199.     headers = request.headers  # 获得headers
  200.  
  201.     # post参数处理，储存到data（字典）
  202.     data = operation.dealPostData(request.data)
  203.  
  204.     token = data['token']  # 获取token
  205.     databaseName = data['databaseName'] # 获取操作的databaseName
  206.     tableName = data['tableName'] # 获取操作的表名
  207.     sqlList = data['sql'] # 获取要执行的sql语句
  208.     dataList = data['data'] #获取要传入的参数
  209.  
  210.     # databaseName中.db后缀处理
  211.     if '.db' in databaseName:
  212.         databaseName = databaseName.replace('.db', '')
  213.  
  214.     userManagenmant = user()  # 实例化user
  215.     dbManagenmant = databaseInformation()  # 实例化databaseInformation
  216.  
  217.     # 查询权限并检查账户
  218.     power = userManagenmant.searchPower(token)
  219.     if power == None:
  220.         return operation.dealReturn(code=401, returnData=None, reason='不合法的账户，token失效或不存在。', tips='请检查token或重新获取token')
  221.  
  222.     # 系统关键数据库禁止修改
  223.     # 初次检查表名
  224.     forbidName = ['databaseInformation','user']
  225.     if databaseName in forbidName:
  226.         return operation.dealReturn(code=403, returnData=None, reason='不合法的操作，当前方法不支持访问核心数据库文件！', tips='请查看api文档检查语法。')
  227.     # 再次遍历sql语句是否合法
  228.     for fName in forbidName:
  229.         for sql in sqlList:
  230.             if fName in sql:
  231.                 return operation.dealReturn(code=403, returnData=None, reason='不合法的操作，当前方法不支持访问核心数据库文件！', tips='请查看api文档检查语法。')
  232.  
  233.     # 验证完毕执行sql语句
  234.     try:
  235.         # 执行语句
  236.         conn = sqlite3.connect(operation.databasePath + databaseName + '.db')  # 连接数据库
  237.         # print("数据库打开成功")
  238.         c = conn.cursor()  # 新建游标
  239.         js = 0
  240.         for sql in sqlList:
  241.             # print(sql)
  242.             # print(tuple(dataList[js]))
  243.             c.execute(sql, tuple(dataList[js]))
  244.             conn.commit()
  245.             js = js + 1
  246.         conn.close()
  247.  
  248.         return operation.dealReturn(code=200, returnData=None, reason='合法请求，执行sql语句成功。', tips=None)
  249.     except Exception as e:
  250.         userManagenmant.close()
  251.         dbManagenmant.close()
  252.         return operation.dealErro(code=500, returnData=None, reason='发生内部错误。错误信息（erro）：' + e, tips='重新尝试操作或联系管理员。')
  253.  
  254.  
  255. # 执行一条查询的sql语句
  256. @app.route('/querySqlExecute',methods=['POST'])
  257. def querySqlExecute():# 执行一条非查询的sql语句
  258.     headers = request.headers  # 获得headers
  259.  
  260.     # post参数处理，储存到data（字典）
  261.     data = operation.dealPostData(request.data)
  262.  
  263.     token = data['token']  # 获取token
  264.     databaseName = data['databaseName']  # 获取操作的databaseName
  265.     tableName = data['tableName']  # 获取操作的表名
  266.     sqlList = data['sql']  # 获取要执行的sql语句
  267.     dataList = data['data']  # 获取要传入的参数
  268.  
  269.     # databaseName中.db后缀处理
  270.     if '.db' in databaseName:
  271.         databaseName = databaseName.replace('.db', '')
  272.  
  273.     userManagenmant = user()  # 实例化user
  274.     dbManagenmant = databaseInformation()  # 实例化databaseInformation
  275.  
  276.     # 查询权限并检查账户
  277.     power = userManagenmant.searchPower(token)
  278.     if power == None:
  279.         return operation.dealReturn(code=401, returnData=None, reason='不合法的账户，token失效或不存在。', tips='请检查token或重新获取token')
  280.  
  281.     # 系统关键数据库禁止修改
  282.     # 初次检查表名
  283.     forbidName = ['databaseInformation', 'user']
  284.     if databaseName in forbidName:
  285.         return operation.dealReturn(code=403, returnData=None, reason='不合法的操作，当前方法不支持访问核心数据库文件！', tips='请查看api文档检查语法。')
  286.     # 再次遍历sql语句是否合法
  287.     for fName in forbidName:
  288.         for sql in sqlList:
  289.             if fName in sql:
  290.                 return operation.dealReturn(code=403, returnData=None, reason='不合法的操作，当前方法不支持访问核心数据库文件！',
  291.                                             tips='请查看api文档检查语法。')
  292.  
  293.     # 验证完毕执行sql语句
  294.     try:
  295.         returnData = []
  296.         # 执行语句
  297.         conn = sqlite3.connect(operation.databasePath + databaseName + '.db')  # 连接数据库
  298.         # print("数据库打开成功")
  299.         c = conn.cursor()  # 新建游标
  300.         js = 0
  301.         for sql in sqlList:
  302.             # print(sql)
  303.             # print(tuple(dataList[js]))
  304.             result = c.execute(sql, tuple(dataList[js]))
  305.             # 结果写入returnData
  306.             returnData.append(result.fetchall())
  307.             js = js + 1
  308.         conn.close()
  309.  
  310.         return operation.dealReturn(code=200, returnData=returnData, reason='合法请求，查询语句成功。', tips=None)
  311.     except Exception as e:
  312.         userManagenmant.close()
  313.         dbManagenmant.close()
  314.         return operation.dealErro(code=500, returnData=None, reason='发生内部错误。错误信息（erro）：' + e, tips='重新尝试操作或联系管理员。')
  315.  
  316.  
  317.  
  318. if __name__ == '__main__':
  319.     app.run()
  1. # -*- coding: utf-8 -*-
  2. """
  3. @connect： 一些常用操作
  4. @Time ： 2022/7/17-2022/7/18
  5. @python ： python3.7 ， flask
  6. @File ：operation.py
  7. @IDE ：PyCharm
  8. @Motto：技术总是要日积月累的
  10. """
  11.  
  12. import traceback
  13. import json,time,os
  14. from flask import Flask,request
  15. from databaseManagement.user import user
  16. from databaseManagement.databaseInformation import databaseInformation
  17.  
  18. class operation:
  19.     debug = None # 继承自falsk的app.debug属性
  20.     adminAccount = None  # 管理者账户
  21.     databasePath = None  # 数据库路径
  22.     totalMemory = None #数据库设定总内存
  23.  
  24.     def __init__(self,debug):
  25.         self.debug = debug
  26.  
  27.         self.userManagenmant = user()  # 实例化user
  28.         self.dbManagenmant = databaseInformation()  # 实例化databaseInformation
  29.  
  30.         self.initOperation()
  31.  
  32.     def initOperation(self): # 初始化常量
  33.         setList = self.dbManagenmant.get_settings()
  34.         self.adminAccount = setList[2] # 管理者账户
  35.         self.databasePath = setList[1] # 数据库路径
  36.         self.totalMemory = setList[0] #数据库设定总内存
  37.  
  38.     def dealPostData(self,data): # 处理post数据
  39.         '''
  40.         post参数处理，储存到data（字典）返回
  41.         :param data: 字节型文本
  42.         :return:
  43.         '''
  44.         data = data.decode('utf-8')
  45.         data = data.replace('\r', '').replace('\n', '')#.replace(' ', '')
  46.         data = json.loads(data)
  47.  
  48.         return data
  49.  
  50.     # 处理未知erro
  51.     def dealErro(self,code,returnData = None ,reason = None,tips = None):
  52.         '''
  53.         处理未知erro
  54.         :param erro:[WinError 2] 系统找不到指定的文件。: 'amadeus.db'
  55.         :return:
  56.         '''
  57.         if self.debug:
  58.             print('发生错误！erro信息：'+ str(reason))
  59.             print('报告错误详细内容及位置：')
  60.             traceback.print_exc()
  61.             print('报告完毕，请及时处理！')
  62.             return self.dealReturn(code,returnData = None ,reason = None,tips = None)
  63.         else:
  64.             return self.dealReturn(code,returnData = None ,reason = None,tips = None)
  65.  
  66.     def dealExceptionRequest(self,reason):
  67.         '''
  68.         处理异常请求
  69.         :param reason: "权限不足！power=%s"
  70.         :return:
  71.         '''
  72.         if self.debug:
  73.             print('获取到一个异常请求，拦截原因:\n\t%s'%reason)
  74.             return json.dumps({"result":403,"reason":reason})
  75.         else:
  76.             return json.dumps({"result": 403, "reason": reason})
  77.  
  78.     def dealReturn(self,code,returnData = None ,reason = None,tips = None):
  79.         '''
  80.         格式化返回信息
  81.         :param code: 操作代码
  82.         :param returnData: 返回数据
  83.         :param reason: 返回原因
  84.         :param tips: 提示操作
  85.         :return: json数据
  86.         '''
  87.         returnJson = {
  88.             'result':code,
  89.             'return':returnData,
  90.             'reason':reason,
  91.             'tips':tips,
  92.         }
  93.         return json.dumps(returnJson)
  94.  
  1. # -*- coding: utf-8 -*-
  2. """
  3. @connect： 查询数据库信息
  4. @Time ： 2022/7/17-2022/7/18
  5. @python ： python3.7 ， flask
  6. @File ：databaseName.py
  7. @IDE ：PyCharm
  8. @Motto：技术总是要日积月累的
  10. """
  11. import sqlite3,random,time
  12.  
  13. class databaseInformation:
  14.     def __init__(self,dbPath = 'database/databaseInformation.db'):
  15.         self.conn = sqlite3.connect(dbPath) # 连接数据库
  16.         #print("数据库打开成功")
  17.         self.c = self.conn.cursor() # 新建游标
  18.  
  19.     def get_databaseName(self): # 返回dbNameList 数据模型如下['286.56.2', '5255324532']
  20.         # 学习：
  21.         # sql = '''select */column from tablename'''
  22.         # "*"代表所有内容。此代码我们搜寻“students”表的所有内容。
  23.         # sql = '''select */column from userToken where column="string"'''
  24.         # sql语句意为从表格中挑选 符合Boolean语句为真的条件 的 全部内容或某些列项 。
  25.         # 如果只是想看students表的id列，eg：select id from students
  26.  
  27.         sql = '''select name from databaseName'''  # 查询 databaseName 的 name 列
  28.         results = self.c.execute(sql)  # 获取结果
  29.         # 数据库将返回结果到results变量中
  30.         all_dbName = results.fetchall()
  31.         # 因为返回的results类似于：<sqlite3.Cursor object at 0x00000257F9100AB0>
  32.         # 所以需要使用fetchall函数把所有结果保存到新的变量中
  33.         # 值如下[('286.56.2',), ('5255324532',)]
  34.  
  35.         # 加工提取ip数据列表
  36.         dbNameList = []
  37.         for ip in all_dbName:
  38.             dbNameList.append(ip[0])
  39.  
  40.  
  41.         return dbNameList
  42.  
  43.     def get_settings(self):# 返回setList 数据模型如下[5368709120, 'E:/Flask/database/', 2061360308)]对应总内存，路径，管理账号
  44.         # 学习：
  45.         # sql = '''select */column from tablename'''
  46.         # "*"代表所有内容。此代码我们搜寻“students”表的所有内容。
  47.         # sql = '''select */column from userToken where column="string"'''
  48.         # sql语句意为从表格中挑选 符合Boolean语句为真的条件 的 全部内容或某些列项 。
  49.         # 如果只是想看students表的id列，eg：select id from students
  50.  
  51.         sql = "select * from setting"  # 查询 databaseName 的 name 列
  52.         results = self.c.execute(sql)  # 获取结果
  53.         # 数据库将返回结果到results变量中
  54.         settings = results.fetchall()
  55.         # 因为返回的results类似于：<sqlite3.Cursor object at 0x00000257F9100AB0>
  56.         # 所以需要使用fetchall函数把所有结果保存到新的变量中
  57.         # 值如下[('5368709120','E:/Flask/database/','2061360308')]对应总内存，路径，管理账号
  58.  
  59.         # 加工提取ip数据列表
  60.         setList = []
  61.         for set in settings[0]:
  62.             setList.append(set)
  63.  
  64.         return setList
  65.  
  66.     def addDatabase(self,name,dbPath):
  67.         try:
  68.             # 获取所有database的名称
  69.             sql = '''select name from databaseName'''
  70.             name_result = self.c.execute(sql)
  71.             name_result = name_result.fetchall()
  72.             nameList = []
  73.             for name_exist in name_result:
  74.                 nameList.append(name_exist[0])
  75.             # 判断所要创建的数据库文件是否已经存在
  76.             if name in nameList:
  77.                 return '已存在'
  78.             else:
  79.                 conn = sqlite3.connect(dbPath)  # 连接数据库
  80.                 conn.close()
  81.                 sql = '''insert into databaseName values(?)'''
  82.                 self.c.execute(sql, (name,))
  83.                 self.conn.commit()
  84.                 return True
  85.         except Exception as e:
  86.             print(e)
  87.             return False
  88.  
  89.  
  90.  
  91.     def close(self):
  92.         # 关闭数据库
  93.         self.conn.commit()  # 提交结果
  94.         self.conn.close() # 关闭数据库
  95.  
  96. if __name__ == '__main__':
  97.     a = databaseInformation('../database/databaseInformation.db')
  98.     print(a.get_databaseName())
  1. # -*- coding: utf-8 -*-
  2. """
  3. @connect： 管理使用的用户
  4. @Time ： 2022/7/17-2022/7/18
  5. @python ： python3.7 ， flask
  6. @File ：user.py
  7. @IDE ：PyCharm
  8. @Motto：技术总是要日积月累的
  10. """
  11. import sqlite3,random,time
  12.  
  13. class user:
  14.     def __init__(self,dbPath = 'database/user.db'):
  15.         self.conn = sqlite3.connect(dbPath) # 连接数据库
  16.         #print("数据库打开成功")
  17.         self.c = self.conn.cursor() # 新建游标
  18.  
  19.  
  20.     def get_ipList(self): # 返回ipList 数据模型如下['286.56.2', '5255324532']
  21.         # 学习：
  22.         # sql = '''select */column from tablename'''
  23.         # "*"代表所有内容。此代码我们搜寻“students”表的所有内容。
  24.         # sql = '''select */column from userToken where column="string"'''
  25.         # sql语句意为从表格中挑选 符合Boolean语句为真的条件 的 全部内容或某些列项 。
  26.         # 如果只是想看students表的id列，eg：select id from students
  27.  
  28.         sql = '''select ip from userToken'''  # 查询 userToken 的 ip 列
  29.         results = self.c.execute(sql)  # 获取结果
  30.         # 数据库将返回结果到results变量中
  31.         all_ip = results.fetchall()
  32.         # 因为返回的results类似于：<sqlite3.Cursor object at 0x00000257F9100AB0>
  33.         # 所以需要使用fetchall函数把所有结果保存到新的变量中
  34.         # 值如下[('286.56.2',), ('5255324532',)]
  35.  
  36.         # 加工提取ip数据列表
  37.         ipList = []
  38.         for ip in all_ip:
  39.             ipList.append(ip[0])
  40.  
  41.  
  42.         return ipList
  43.  
  44.     def get_tokenList(self): # 返回token 数据模型如下['286.56.2', '5255324532']
  45.         # 学习：
  46.         # sql = '''select */column from tablename'''
  47.         # "*"代表所有内容。此代码我们搜寻“students”表的所有内容。
  48.         # sql = '''select */column from userToken where column="string"'''
  49.         # sql语句意为从表格中挑选 符合Boolean语句为真的条件 的 全部内容或某些列项 。
  50.         # 如果只是想看students表的id列，eg：select id from students
  51.  
  52.         sql = '''select token from userToken'''  # 查询 userToken 的 token 列
  53.         results = self.c.execute(sql)  # 获取结果
  54.         # 数据库将返回结果到results变量中
  55.         all_token = results.fetchall()
  56.         # 因为返回的results类似于：<sqlite3.Cursor object at 0x00000257F9100AB0>
  57.         # 所以需要使用fetchall函数把所有结果保存到新的变量中
  58.         # 值如下[('286.56.2',), ('5255324532',)]
  59.  
  60.         # 加工提取ip数据列表
  61.         tokenList = []
  62.         for ip in all_token:
  63.             tokenList.append(ip[0])
  64.  
  65.         return tokenList
  66.     def creatToken(self):
  67.       """
  68.       生成一个指定长度的随机字符串，充当token
  69.       """
  70.       randomlength = 36 # 定义字符串长度
  71.  
  72.       random_str =''
  73.       base_str ='@#$%^&*()_+|=-!~`.,?:;ABCDEFGHIGKLMNOPQRSTUVWXYZabcdefghigklmnopqrstuvwxyz0123456789'
  74.       length =len(base_str) -1
  75.       for i in range(randomlength):
  76.         random_str +=base_str[random.randint(0, length)]
  77.  
  78.       return random_str
  79.  
  80.  
  81.  
  82.     def addToken(self,ip,token,power): # 添加新的token
  83.         sql = "INSERT INTO userToken values(?,?,?,?)" # 添加值
  84.  
  85.         ts = time.time()
  86.         try:
  87.             insertResults = self.c.execute(sql, (
  88.             ip,token, ts,power))  # 执行sql语句 数据大概像这个样子(ip=string,token=string,时间戳,权限)
  89.             # 数据库将返回结果到results变量中
  90.             self.conn.commit()  # 提交结果
  91.  
  92.             return True
  93.         except:
  94.             return insertResults
  95.  
  96.     def searchToken(self,ip): # 返回token 数据模型如下['286.56.2', '5255324532']
  97.         '''
  98.         :param ip: '192.168.0.100'
  99.         :return: 'o:c8N3:9vl#bnmMsl#\\LD=%\\83`ZWvGs&dgk'
  100.         '''
  101.  
  102.         # 学习：
  103.         # sql = '''select */column from tablename'''
  104.         # "*"代表所有内容。此代码我们搜寻“students”表的所有内容。
  105.         # sql = '''select */column from userToken where column="string"'''
  106.         # sql语句意为从表格中挑选 符合Boolean语句为真的条件 的 全部内容或某些列项 。
  107.         # 如果只是想看students表的id列，eg：select id from students
  108.  
  109.         sql = '''select token from userToken where ip="%s"'''%ip  # 查询 userToken 中 指定token
  110.         results = self.c.execute(sql)  # 执行sql
  111.         # 数据库将返回结果到results变量中
  112.         token = results.fetchall()
  113.         # 因为返回的results类似于：<sqlite3.Cursor object at 0x00000257F9100AB0>
  114.         # 所以需要使用fetchall函数把所有结果保存到新的变量中
  115.         # 值如下[('o:c8N3:9vl#bnmMsl#\\LD=%\\83`ZWvGs&dgk',)]
  116.  
  117.         # 加工提取token值
  118.         token = token[0][0]
  119.  
  120.         return token
  121.  
  122.     def updateTime(self,ip):
  123.         '''
  124.         :param ip: '192.168.0.100'
  125.         :return: bool
  126.         '''
  127.  
  128.         try:
  129.             sql = "UPDATE userToken SET time=? WHERE ip=?"
  130.             self.c.execute(sql,(time.time(),ip))  # 执行sql
  131.             self.conn.commit()  # 提交结果
  132.  
  133.             return True
  134.         except:
  135.             return False
  136.  
  137.     def searchPower(self,token):
  138.         '''
  139.         :param token: 'o:c8N3:9vl#bnmMsl#\\LD=%\\83`ZWvGs&dgk'
  140.         :return: 0
  141.         '''
  142.  
  143.         try:
  144.             sql = '''select power from userToken WHERE token=?'''
  145.             results = self.c.execute(sql,(token,)) # 执行sql
  146.  
  147.             # 数据库将返回结果到results变量中
  148.             power = results.fetchall()
  149.             # 因为返回的results类似于：<sqlite3.Cursor object at 0x00000257F9100AB0>
  150.             # 所以需要使用fetchall函数把所有结果保存到新的变量中
  151.             # 值如下[('o:c8N3:9vl#bnmMsl#\\LD=%\\83`ZWvGs&dgk',)]
  152.  
  153.             # 加工提取token值
  154.             power = power[0][0]
  155.  
  156.             return power
  157.         except:
  158.             return None
  159.  
  160.     def close(self):
  161.         # 关闭数据库
  162.         self.conn.commit()  # 提交结果
  163.         self.conn.close() # 关闭数据库
  164.  
  165. if __name__ == '__main__':
  166.     a = user('../database/user.db')
  167.     print(a.searchPower(''))
'
运行
  1. <!DOCTYPE html>
  2. <html lang="zh">
  3. <head>
  4.     <meta charset="UTF-8">
  5.     <title>云数据库API</title>
  6.     <link rel="shortcut icon" href="static/cloudDatabase.jpg">
  7. </head>
  8. <body>
  9. <div align="center" id = "frame">
  10.     <div align="center" id = "main">
  11.         <img src="static/top.png">
  12.         <div align="center" id = "connect">
  13.             <p id = "title">恭喜！您的云数据库API搭建成功。</p>
  14.             <p id = "text">
  15.             在线API文档地址：
  16.                 <a target=_blank href="https://www.apifox.cn/apidoc/shared-93936f73-c065-480b-83b1-5f87f13916ed">点击打开apifox上分享的文档</a>
  17.                 <br/>
  18.             管理员:
  19.                 <br>
  20.             管理员联系方式：
  21.                 <br>
  22.             开发者：盧瞳
  23.                 <br>
  24.             开发者联系方式：QQ:2061360308
  25.                 <br>
  26.             原文链接：
  27.                 <br>
  28.             GitHUb项目地址：
  29.             </p>
  30.         </div>
  31.     </div>
  32. </div>
  33. <style>
  34.     #frame {
  35.         //background-color: #fe7fac;
  36.         width: document.body.clientWidth;
  37.         height: document.body.clientHeight;
  38.         vertical-align:middle;
  39.     }
  40.     #main {
  41.         background-color: #66CCFF;
  42.         width: 600px;
  43.         height: 100%;
  44.         vertical-align:middle;
  45.     }
  46.     img {
  47.         top:50px;
  48.         left:50px;
  49.         width: 600px;
  50.         height: 120px;
  51.         float: left;
  52.     }
  53.     #title {
  54.         font-size:28px
  55.     }
  56.     #text{
  57.         text-align:left;
  58.     }
  59. </style>
  60. </body>
  61. </html>

再之后是SDK与文档，这两个接口这么能缺呢？

文档这里我推荐Apifox他们的软件很好用界面也简洁易懂，功能也齐全，这里放本文的在线文档链接，有兴趣的同学可以点开翻一翻。文档地址

SDK也就是把上面接口用requests库做个包装，我简单写了一些代码：

  1. # -*- coding: utf-8 -*-
  2. """
  3. @connect： 面向python的云数据库SDK
  4. @Time ： 2022/1/18 11:36
  5. @Auth ： 技术空间
  6. @File ：main.py
  7. @IDE ：PyCharm
  8. @Motto：技术总是要日积月累的
  10. """
  11. import time
  12.  
  13. import requests,json,socket
  14. from urllib import parse
  15. from pythonSdk.operation import operation
  16.  
  17. class clouldDatabaseSDK:
  18.     operation = operation() # 引入一些常用方法
  19.     # 请求头
  20.     header = {
  21.         "Accept": "*/*",
  22.         "Accept-Encoding": "gzip, deflate, br",
  23.         "Accept-Language": "zh-CN,zh;q=0.9",
  24.         "Connection": "keep-alive",
  25.         "Content-Type": "application/json",
  26.         "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/92.0.4515.159 Safari/537.36"
  27.     }
  28.     severUrl = None # 服务器地址
  29.     ip = None # 请求用的本机ip地址
  30.     # 获取本机IP
  31.     hostname = socket.gethostname()
  32.     ip = socket.gethostbyname(hostname)
  33.  
  34.     adminAccount = None # 管理者账户
  35.     token = None # 服务器返回零时token
  36.  
  37.     def __init__(self,serverUrl,adminAccount=None):
  38.         '''
  39.         初始化SDK
  40.         :param url:服务器请求地址
  41.         :param adminAccount:账户,没有不填用于验证管理者权限的
  42.         '''
  43.         self.severUrl = serverUrl
  44.         self.adminAccount = adminAccount
  45.  
  46.         # 调用初始化接口获取token
  47.         post_json = json.dumps({'userId': self.adminAccount, 'ip': self.ip})
  48.         print(post_json)
  49.  
  50.         # 处理返回内容
  51.         requestReturn = operation.dealRequestReturn(self.operation,requests.post(parse.urljoin(self.severUrl,"init"), data=post_json, headers=self.header))
  52.         # 验证返回内容
  53.         if requestReturn.statusCode == 200:
  54.             self.token = requestReturn.returnData['token']
  55.         else:
  56.             print(requestReturn.requestInformation)
  57.  
  58.     def queryDBInformation(self):
  59.         '''
  60.         查询数据库信息，需管理员权限
  61.         :return:
  62.         '''
  63.         post_json = json.dumps({'token': self.token})
  64.  
  65.         # 处理返回内容
  66.         requestReturn = operation.dealRequestReturn(operation,requests.post(parse.urljoin(self.severUrl, "information"), data=post_json,
  67.                                                                   headers=self.header))
  68.         # 验证返回内容
  69.         if requestReturn.statusCode == 200:
  70.  
  71.             return requestReturn
  72.         else:
  73.             print(requestReturn.requestInformation)
  74.  
  75.     def addDatabase(self,databaseName):
  76.         '''
  77.         添加数据库，需管理员权限
  78.         :param databaseName:要添加的数据库名称
  79.         :return:
  80.         '''
  81.         post_json = json.dumps({'token': self.token,"databaseName":databaseName,"time":time.time()})
  82.  
  83.         # 处理返回内容
  84.         requestReturn = operation.dealRequestReturn(operation,requests.post(parse.urljoin(self.severUrl, "/addDatabase"), data=post_json,
  85.                                                                   headers=self.header))
  86.         # 验证返回内容
  87.         if requestReturn.statusCode == 200:
  88.             return requestReturn
  89.         else:
  90.             print(requestReturn.requestInformation)
  91.  
  92.     def notQuerySqlExecute(self,databaseName,tableName,sql,data):
  93.         '''
  94.         执行一条非查询的sql语句
  95.         :param databaseName: 要操作的数据库名称
  96.         :param tableName: 要操作的表名
  97.         :param sql: sql语句列表 --> []
  98.         :param data: 传入sql语句中参数列表 --> []
  99.         :return:
  100.         '''
  101.  
  102.         post_json = json.dumps({'token': self.token,"databaseName":databaseName,"tableName":tableName,"sql":sql,"data":data})
  103.  
  104.         # 处理返回内容
  105.         requestReturn = operation.dealRequestReturn(operation,requests.post(parse.urljoin(self.severUrl, "/notQuerySqlExecute"), data=post_json,
  106.                                                                   headers=self.header))
  107.         # 验证返回内容
  108.         if requestReturn.statusCode == 200:
  109.             return requestReturn
  110.         else:
  111.             print(requestReturn.requestInformation)
  112.  
  113.     def querySqlExecute(self,databaseName,tableName,sql,data):
  114.         '''
  115.         执行一条查询的sql语句
  116.         :param databaseName: 要操作的数据库名称
  117.         :param tableName: 要操作的表名
  118.         :param sql: sql语句列表 --> []
  119.         :param data: 传入sql语句中参数列表 --> []
  120.         :return:
  121.         '''
  122.  
  123.         post_json = json.dumps({'token': self.token,"databaseName":databaseName,"tableName":tableName,"sql":sql,"data":data})
  124.  
  125.         # 处理返回内容
  126.         requestReturn = operation.dealRequestReturn(operation,requests.post(parse.urljoin(self.severUrl, "/querySqlExecute"), data=post_json,
  127.                                                                   headers=self.header))
  128.         # 验证返回内容
  129.         if requestReturn.statusCode == 200:
  130.             return requestReturn
  131.         else:
  132.             print(requestReturn.requestInformation)
  133.  
  134. if __name__ == '__main__':
  135.     # a=clouldDatabaseSDK(serverUrl='http://101.42.163.114:5000/',adminAccount='2061360308')
  136.     a = clouldDatabaseSDK(serverUrl='http://192.168.0.101:5000', adminAccount='2061360308')
  137.  
  138.     #a.addDatabase('测试用数据库')
  139.     '''create table if not exists 测试用表(roollno real,name text,class real)''',
  140.     insertQuary = a.notQuerySqlExecute('测试用数据库','测试用表',
  141.                          ['''create table if not exists 测试用表(roollno real,name text,class real)''',
  142.                              '''insert into 测试用表 values(?,?,?)''',
  143.                                           '''insert into 测试用表 values(?,?,?)''',
  144.                                           ],
  145.                          [
  146.                              [],
  147.                              [0,1,2],
  148.                              ['roollno','name','class']
  149.                           ]
  150.                          )
  151.     selectQuary = a.querySqlExecute('测试用数据库', '测试用表',
  152.                          ['''select * from 测试用表''',
  153.                           ],
  154.                          [
  155.                              [],
  156.                          ]
  157.                          )
  158.     query = a.queryDBInformation()
  159.     #print('返回:',query.statusCode,query.returnData)
  160.     print(insertQuary.statusCode,insertQuary.returnData)
  161.     print(selectQuary.statusCode,selectQuary.returnData)
  1. # -*- coding: utf-8 -*-
  2. """
  3. @connect： 一些常用操作
  4. @Time ： 2022/7/17-2022/7/18
  5. @python ： python3.7 ， flask
  6. @File ：operation.py
  7. @IDE ：PyCharm
  8. @Motto：技术总是要日积月累的
  10. """
  11.  
  12. import requests,json,socket
  13. from urllib import parse
  14.  
  15. class operation:
  16.     def __init__(self):
  17.         pass
  18.     def dealRequestReturn(self,object):
  19.         '''
  20.         处理请求返回
  21.         :param object: requests.post返回对象
  22.         :return: 字典，数组等json.loads数据
  23.         '''
  24.         requestReturn = object.text # 获取返回json内容
  25.         print(requestReturn)
  26.         requestReturn = json.loads(requestReturn) # 解析json
  27.         #requestReturn = json.loads('{"result": 200, "return": {"token": "", "time": 1658243312.8069735}, "reason": "\u5408\u6cd5\u8bf7\u6c42\uff0c\u8bf7\u6c42\u6210\u529f\u3002", "tips": null}')  # 解析json
  28.         statusCode = requestReturn['result']
  29.         returnData = requestReturn['return']
  30.         if statusCode == 200:
  31.             requestInformation = '请求成功！\n状态码：' + str(requestReturn['result']) + '\n原因：' + str(requestReturn[
  32.                 'reason']) + '\n提示：' + str(requestReturn['tips'])
  33.         else:
  34.             requestInformation = '请求失败！\n状态码：' + str(requestReturn['result']) + '\n原因：' + str(requestReturn[
  35.                 'reason']) + '\n提示：' + str(requestReturn['tips'])
  36.  
  37.         #构建类对象返回
  38.         class requestReturn():
  39.             '''
  40.             请求返回内容对象
  41.             :object statusCode: 状态码
  42.             :object returnData：返回的数据
  43.             :object requestInformation：返回的提示
  44.             '''
  45.             def __init__(self,statusCode,returnData,requestInformation):
  46.                 self.statusCode = statusCode
  47.                 self.returnData = returnData
  48.                 self.requestInformation = requestInformation
  49.         requestReturn = requestReturn(statusCode,returnData,requestInformation)
  50.         return requestReturn
'
运行

代码ok了，想要真正让接口在服务器上跑起来，还需要一些配置：

首先host=“0.0.0.0”这个我们支前准备好了，还有就是在服务器上将你的端口号加进去，因为服务器厂商太多这里不做详细解说，有需要可以百度“Flask公网访问”，这里放一个腾讯云设置方法的教程地址

文章结束，感谢  收藏+关注，希望本文对你有所启发。

具体的源码和SDK我打包放这里了，源码地址。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家小花儿/article/detail/889537
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号