mysql - python开发web service 中数据库链接和释放应该怎么处理?
问题描述
用tornado开发web service服务。服务端根据接收到的json数据对mysql数据库进行查询,并把结果反馈给用户。采用sqlalchemy对数据库进行操作,以下对数据库链接的创建,释放是否合理呢?
class db: def __init__(self,db_ip=’’,db_name=’’,db_user=’’,db_pass=’’,db_charset=’’):self.db_str = ’mysql+pymysql://’+db_user+’:’+db_pass+’@’+db_ip+’:3306/’+db_name+’?’+’charset=’+db_charsetself.engine = create_engine(self.db_str, encoding=’utf-8’, echo=False)self.dbsession = sessionmaker(bind=self.engine) def return_dbsession(self):return self.dbsession def close_session(self):self.session.close()
database = db(db_ip=’127.0.0.1’, db_name=’data_utf’, db_user=’root’, db_pass=’root’, db_charset=’utf8’)
处理post请求代码如下
class rcvRequest(tornado.web.Request): session = scoped_session(database.return_dbsession())() response = [] for ctt in session.query(table).filter(table.ID == id):response.append(ctt) self.write(str(response)) session.close()
问题解答
回答1:不合理,每来一次请求就建立一次连接不是很浪费吗?sqlalchemy可以很好的帮你管理连接池,找找资料,用连接池吧.
回答2:代码调整为以下这种方式是否合理?
def db(db_ip=’’,db_name=’’,db_user=’’,db_pass=’’,db_charset=’’):db_str = ’mysql+pymysql://’+db_user+’:’+db_pass+’@’+db_ip+’:3306/’+db_name+’?’+’charset=’+db_charsetengine = create_engine(self.db_str, encoding=’utf-8’, echo=False)dbsession = sessionmaker(bind=self.engine)return dbsessiondatabase =db(db_ip=’127.0.0.1’, db_name=’data_utf’, db_user=’root’, db_pass=’root’, db_charset=’utf8’)class rcvRequest(tornado.web.Request): def initialize(self):self.session = scoped_session(database)() @tornado.gen.coroutine def post(self):response = []for ctt in self.session.query(table).filter(table.ID == id): response.append(ctt)self.write(str(response))def on_finish(self):self.session.close()回答3:
还是建议找个ORM吧。你这样一个链接就请求一次搞不好数据服务就挂掉了。
回答4:请参考https://github.com/PyMySQL/To...
相关文章:
1. dologin说是没有定义2. 问一下代码哪里出错了????3. mysql - 数据库建字段,默认值空和empty string有什么区别 1104. 冒昧问一下,我这php代码哪里出错了???5. python - UTC格式转换成本地时间6. angular.js - 在ionic下,利用javascript导入百度地图,pc端可以显示,移动端无法显示7. 求问:其它输出都正常,就是错误输出是乱码!8. mybatis - Java关于Mysql的随机id生成9. windows - Mysql数据库部署 能否不安装服务?10. python - 如何使用requests模块在一个post中提交含有多个相同名称的数据?