主页 / dba / 问题 / 315508
Accepted
Chris
Asked: 2022-08-12 04:38:33 +0800 CST

程序未正确循环

  • 772

我在一台服务器上有几个客户端数据库。它们都有一个前缀。为此，让我们使用“piggy_”作为前缀。

IE

piggy_client_a
piggy_client_b
piggy_client_c

下面是三个小猪数据库的代码并添加了一堆用户。（用于检测）：

CREATE SCHEMA IF NOT EXISTS piggy_client_a;

CREATE TABLE piggy_client_a.user (
  id INT(11) NOT NULL AUTO_INCREMENT,
  fullname VARCHAR(30) DEFAULT NULL,
  email VARCHAR(100) DEFAULT NULL,
  PRIMARY KEY (id)
) ENGINE=INNODB DEFAULT CHARSET=utf8;

INSERT INTO piggy_client_a.user (fullname, email) VALUES
("chris davis", "chris@something.com"),
("chris td", "chris@something.com"),
("bob sinclair", "bob@spectrum.net"),
("frank sidebottom", "frank@bighead.com");

CREATE SCHEMA IF NOT EXISTS piggy_client_b;

CREATE TABLE piggy_client_b.user (
  id INT(11) NOT NULL AUTO_INCREMENT,
  fullname VARCHAR(30) DEFAULT NULL,
  email VARCHAR(100) DEFAULT NULL,
  PRIMARY KEY (id)
) ENGINE=INNODB DEFAULT CHARSET=utf8;

INSERT INTO piggy_client_b.user (fullname, email) VALUES
("fanny adams", "chris@elsewhere.net"),
("colin furry", "colin@something.com"),
("chris grumps", "grumpy@htom.com"),
("tracey singer", "trace@email.com");

CREATE SCHEMA IF NOT EXISTS piggy_client_c;

CREATE TABLE piggy_client_c.user (
  id INT(11) NOT NULL AUTO_INCREMENT,
  fullname VARCHAR(30) DEFAULT NULL,
  email VARCHAR(100) DEFAULT NULL,
  PRIMARY KEY (id)
) ENGINE=INNODB DEFAULT CHARSET=utf8;

INSERT INTO piggy_client_c.user (fullname, email)VALUES
("mary qos", "mary@comms.com"),
("curtis jackson", "curtis@something.com"),
("christine motor", "chrissy@live.net"),
("tom peters", "tom@peters.org");

每个 piggy 数据库中都有相同的模式。其中一个表是user，我想找到用户所在的任何这些数据库。

我写了一个存储过程，总体上它可以工作。然而，它只处理第一个小猪数据库。我已经仔细检查过，如果我将特定用户添加到piggy_client_c数据库中，它不会被返回。

这是我的代码：

DELIMITER $$
DROP PROCEDURE IF EXISTS `find_user`$$

CREATE PROCEDURE `find_user`(IN partial_name VARCHAR(20))
BEGIN

    DECLARE database_name VARCHAR(128) DEFAULT '';
    DECLARE non_found INTEGER DEFAULT 0;

    DECLARE database_list 
        CURSOR FOR 
            SELECT SCHEMA_NAME FROM information_schema.SCHEMATA 
            WHERE SCHEMA_NAME LIKE `piggy_client_%` 
            ORDER BY SCHEMA_NAME ASC;

    DECLARE CONTINUE HANDLER FOR NOT FOUND SET non_found = 1;

    OPEN database_list;

    check_table: LOOP

        FETCH database_list INTO database_name;

        IF non_found = 1 THEN 
            LEAVE check_table;
        END IF;

        SET @sql = CONCAT('SELECT "',database_name,'" AS db_name, fullname,email FROM ',database_name,'.user WHERE trim(fullname) like "%',partial_name,'%"');

        PREPARE db_statement FROM @sql;
        EXECUTE db_statement;
        DEALLOCATE PREPARE db_statement;

    END LOOP check_table;

    CLOSE database_list;

END$$

DELIMITER ;

我看不到任何会导致函数退出或不循环光标的东西，但我对此相当陌生。

或者，如果我可以“单步执行”代码，那将很有用，或者输出调试信息。

TIA，克里斯

mysql stored-procedures

1 个回答

  1. Best Answer

    在您的代码中有一个错误：

    SELECT SCHEMA_NAME FROM information_schema.SCHEMATA 
WHERE SCHEMA_NAME LIKE `piggy_client_%` 
ORDER BY SCHEMA_NAME ASC;

    用字符串分隔符替换反引号，如下所示：

    SELECT SCHEMA_NAME FROM information_schema.SCHEMATA 
WHERE SCHEMA_NAME LIKE 'piggy_client_%' 
ORDER BY SCHEMA_NAME ASC;

    我创建了一个db-fiddle

    您还误用双引号作为字符串分隔符。您的插入语句应如下所示：

    ('fanny adams', 'chris@elsewhere.net'),

    但显然这有效，所以我还没有解决这个问题。

    • 3

相关问题