如何在请求时获取有关连接ID的信息?

How to get info about connection Id at request?(如何在请求时获取有关连接ID的信息?)
本文介绍了如何在请求时获取有关连接ID的信息?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我希望在执行长查询时获得连接ID(ThreadID),以防前端(Vue.js)的用户想要取消查询(以防查询永远不结束...)。因此,当用户点击"停止查询"时,我将对MySQL..执行KILL(ThreadID)

我正在与KNOW(CLIENT=MySQL)一起使用池化。我相信这是一件微不足道的事情,但可以请某人描述一下我如何访问它。我的后端(node.js)的设置不同-是由一个聪明人创建的,他定义池和连接如下:

connection.connect(function(err) {
  if (err) {
    console.error('error connecting: ' + err.stack);
    return;
  }

  console.log('connected as id ' + connection.threadId);
});
const knex = require("knex");

// Helpers -------------------------------------------------------------------
const connection = (user, password) =>
  knex({
    client: "mysql",
    connection: {
      multipleStatements: true,
      host: process.env.MYSQL_IP,
      port: process.env.MYSQL_PORT,
      user,
      password,
      database: "",
      dateStrings: true,
      idleTimeoutMillis: -1
    },
    debug: true,
    pool: {
      min: 0,
      max: 7
    }
  });

const knex_session = pool => (user, password) => {
  if (pool[user] === undefined) {
    pool[user] = connection(user, password);
  }
  return pool[user];
};

// Pool ----------------------------------------------------------------------
const connections = {};

// Exports -------------------------------------------------------------------
exports.admin = connection(
  process.env.MYSQL_USERNAME,
  process.env.MYSQL_PASSWORD
);
exports.client = knex_session(connections);

// ---------------------------------------------------------------------------

我正在寻找一种以某种方式获取MySQL线程ID的方法--我想是从函数(路由)获得的。其他选项是对MySQL的其他调用(SELECT CONNECTION_ID()),或者通过某种方式从请求对象中提取数据(然而,在这里也不成功)。 然后执行KILL QUERY(ThreadID)以确保查询不会挂起,并确保我可以向用户显示正确的VUE组件。

推荐答案

正如您已经发现的,MySQL connection id是Connection对象的属性:connection.threadId。knex也是如此,因为它位于mysql之上。

只要它在作用域中,您就可以从Connection对象中获取它,并将其放在一个有用的位置……如果你是快递的话就是这样的。

    function whatever (req, res, next) {
       ...
       res.dbmsThreadId = connection.threadId
       ...
    }

这篇关于如何在请求时获取有关连接ID的信息?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!

相关文档推荐

Hibernate reactive No Vert.x context active in aws rds(AWS RDS中的休眠反应性非Vert.x上下文处于活动状态)
Bulk insert with mysql2 and NodeJs throws 500(使用mysql2和NodeJS的大容量插入抛出500)
Flask + PyMySQL giving error no attribute #39;settimeout#39;(FlASK+PyMySQL给出错误,没有属性#39;setTimeout#39;)
auto_increment column for a group of rows?(一组行的AUTO_INCREMENT列?)
Sort by ID DESC(按ID代码排序)
SQL/MySQL: split a quantity value into multiple rows by date(SQL/MySQL:按日期将数量值拆分为多行)