从数据库上的行锁定是否也适用于主数据库?

h5qlskok  于 2021-06-20  发布在  Mysql
关注(0)|答案(1)|浏览(347)

例如,在交易中,

  1. START TRANSACTION;
  2. SELECT count(*) as count FROM `order` WHERE user_id = 25286 LOCK IN SHARE MODE;
  3. INSERT INTO `order` (`id`, `user_id`, `product_id`) VALUES (NULL, '25286', '36296');

我们执行 SELECT LOCK IN SHARE MODE; 这个 SELECT 查询将在从属数据库上执行并锁定一行。
是吗 SELECT LOCK IN SHARE MODE 还要在主数据库上创建行锁定,以便插入查询不会在主数据库上运行?

ogsagwnx

ogsagwnx1#

否-锁定不会渗透到整个服务器。因此,从服务器上的显式锁基本上不会锁定主服务器中相应的表,反之亦然。
我们在本例中使用的一个简单的解决方法是将所有这些特定的锁定查询只指向主服务器。因此,无论哪个客户端会话正在运行,这些查询总是只在主服务器上运行。这样就可以处理并发连接问题。
我在php代码中做了类似的过滤。为了将查询定向到相关服务器(将查询读取到从属服务器,将查询写入主服务器),编写了一个自定义函数来标识查询的类型。
值得注意的一点是,事务/锁定/解锁操作中的查询始终被视为写查询。
另外,对于 Set ,仅限 SET AUTOCOMMIT 以及 SET TRANSACTION 是写命令。
请在下面找到我们正在使用的实际代码的大致精简版本:

  1. /*
  2. * All the WRITE operation commands
  3. * /
  4. $write_commands = array(
  5. 'create',
  6. 'alter',
  7. 'drop',
  8. 'truncate',
  9. 'comment',
  10. 'rename',
  11. 'insert',
  12. 'update',
  13. 'delete',
  14. 'merge',
  15. 'call',
  16. 'lock',
  17. 'unlock',
  18. 'start',
  19. 'commit',
  20. 'rollback',
  21. 'savepoint',
  22. 'set',
  23. 'replace'
  24. );
  25. /*
  26. * method to determine whether Read or Write
  27. * @param $sql String (SQL query string)
  28. * @return: void
  29. * /
  30. function determineReadOrWrite(string $sql): void {
  31. $dml_query = false;
  32. $words = str_word_count(strtolower(trim($sql)), 1);
  33. $first_word = isset($words[0]) ? $words[0] : '';
  34. $second_word = isset($words[1]) ? $words[1] : '';
  35. if (in_array($first_word, $this->write_commands)) {
  36. /* if it is not "set" then we set to master link */
  37. if ($first_word !== 'set'
  38. || ($first_word === 'set' && $second_word === 'autocommit')
  39. || ($first_word === 'set' && $second_word === 'transaction')
  40. ) {
  41. $dml_query = true;
  42. /* If we Lock tables or Begin a Transaction, we should run on Write servers only */
  43. /* till we Commit/Rollback or Unlock Tables */
  44. if(($first_word === 'start' && $second_word === 'transaction')
  45. || $first_word === 'lock'){
  46. /* Set whether the current query is starting a Transaction / Lock etc */
  47. $this->wait_for_commit_rollback = true;
  48. }
  49. /* We are doing Commit/Rollback or Unlock Tables */
  50. if ($first_word === 'commit'
  51. || $first_word === 'rollback'
  52. || $first_word === 'unlock') {
  53. $this->wait_for_commit_rollback = false;
  54. }
  55. }
  56. }
  57. /* It's a insert/update/delete/etc query - to be run on Write Db only */
  58. if ($dml_query || $this->wait_for_commit_rollback) {
  59. $this->setActiveConnectionToWrite(true);
  60. } else {
  61. $this->setActiveConnectionToRead();
  62. }
  63. }
展开查看全部

相关问题