如何使MySQL前后端连接SESSION变量保持一致

最近在开发MySQL代理中间件过程中, 遇到这样一个问题: 当前后端连接不是一一对应的关系时, 对前端连接设置SESSION级别的变量时, 如何能使前端后变量的值保持一致?

一个直观的实现方式是, 拦截SET语句, 判断scope是SESSION时, 将变量的值保存在前端连接中. 当执行其他查询语句时, 在获取后端连接后, 先将前端连接中保存的变量逐一发送到后端连接, 然后执行查询语句, 释放后端连接时再将变量的值恢复.

这种实现方式存在几个显著的问题.

1 存在一定的性能损耗, 至少增加了1次与后端MySQL的交互. 但是, 这也是后端连接池方案都会遇到的问题, 前后端连接绑定不存在这种问题, 但是也就失去了连接池带来的好处.

2 需要判断参数值是否合法, 实现起来非常繁琐. 例如, 如果考虑支持字符集设置, 就要枚举出MySQL支持的所有字符集及字符序类型, 解析 SET NAMES 'utf8' COLLATE 'utf8_general_ci' 时, 对字符集和字符序进行合法性判断. 对于某些参数, 例如sql_mode, 还需要考虑MySQL版本之前的差异.

在这种实现方式下, 有几个优化点可以参考.

1 批量执行SET语句. MySQL语法层面支持 SET SESSION var1 = val1, SESSION var2 = val2, 因此不论前端连接接收到的SET语句是单条的还是批量的, 在将这些kv值发往后端时, 可以整合成一条SQL, 从而减少与MySQL的交互次数, 提高执行效率.

2 后端连接按需重置. 当归还后端连接时, 不再重置连接, 而是在下一次获取连接时, 先判断连接中的变量值与前端连接是否全部相同, 如果全部相同, 则不需要重置, 可以直接使用, 否则, 将那些值不相同的变量设置到后端连接.

3 使用 COM_RESET_CONNECTION 命令重置连接. COM_RESET_CONNECTION命令可以将连接恢复到初始状态, 具体内容可参考文档: https://dev.mysql.com/doc/refman/5.7/en/mysql-reset-connection.html . 但是, 如果连接创建时的状态不是连接的默认状态, 就不能使用这种方式重置连接. 例如, 在启动mysql client时指定的字符集不是DEFAULT, 那么执行该命令后会错误地把连接的字符集设置成DEFAULT.

最后, 如果你有更好的解决方案, 欢迎讨论交流.

var mysql = require('mysql')

var conn = mysql.createConnection({

host: 'localhost',

user: 'root',

password: '',

database:'nodejs',

port: 3306

})

conn.connect()

//查询

// conn.query('SELECT * from user where name="wangzhiwei"', function(err, result) {

// if (err) throw err

// console.log(result)

// })

//新增

// conn.query('insert into user (username,password) values("huxiaona","123456")', function(err, result) {

// if (err) throw err

// console.log(result)

// })

//删除

// conn.query('delete from user where username="wupeigui"', function(err, result) {

// if (err) throw err

// console.log(result)

// })

conn.query('update user set id="1" where username="huxiaona"',function(err,result){

if (err) {throw err}

console.log("修改数据成功")

})

conn.end()

具体连接方法如下：

1、打开HBuilder工具，在Web项目中的js文件夹中，新建JavaScript文件ConnDB.js

使用require()引入mysql模块，然后赋值给变量mysql

3、再调用createConnection()方法，设置主机、用户名、密码、端口和数据库

4、调用mysql模块中的connect()方法，连接mysql数据库

5、编写一个查询语句SQL，以字符串形式赋值给变量sql

6、最后调用query()方法，通过返回的值进行判断，然后打印返回成功的值

---