metaData.getPrimaryKeys() returns key为单条时4条相同的记录

metaData.getPrimaryKeys() returns four same records when the key is single

我的问题与 类似,但有点不同。我正在使用 java 中的以下代码检索 table 的主键:

DatabaseMetaData meta = connection.getMetaData();
ResultSet rs = meta.getPrimaryKeys(null, null, "global_settings");
while (rs.next()) {
     System.out.println(rs.getString("COLUMN_NAME"));
}

Table global_settings 只有一个主键列,即 global_setting_id。 但是,循环似乎运行了四次,输出为:

global_setting_id
global_setting_id
global_setting_id
global_setting_id

但是,对于带有复合键的 table,循环工作正常,例如对于 Table user_info 有三列构成复合主键,即 (user_id,national_id, taxation_id),

循环提供的输出为:

user_id
national_id
taxation_id

我正在使用mysql,驱动程序是

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.18</version>
</dependency>

有点琐碎,但对我正在做的作业来说仍然是一个问题。这是我这边的错误还是问题?

因此,在放弃一段时间后,我在尝试其他方法时不小心遇到了这个问题。背景是我有四个数据库,其中有一些 table 共享相同的 table 名称,例如 user_accounts、global_settings 等。 我发现的问题是:

  • 我没有在
  • 的参数中指定手头的 table 属于哪个数据库
   getPrimaryKeys(catalog, schema, table_name)

正确的做法是

   getPrimaryKeys("my_database", null, "my_table")

我没有指定数据库的原因是因为我认为连接字符串即

DriverManager.getConnection("jdbc:mysql://localhost:3306/my_database?..."

使操作非常特定于指定的数据库。 我错过了 documentation 所说的内容:

catalog - a catalog name; must match the catalog name as it is stored in the database; "" retrieves those without a catalog; null means that the catalog name should not be used to narrow the search

  • 与我连接的用户拥有所有其他四个数据库的所有权限。这意味着不指定我正在连接的数据库允许 "intrusion" 从用户也可以访问的其他数据库中的 table 获取主键列。正如我刚才解释的,我不知道单个数据库连接允许这种 "intrusive" 操作。

现在,您可能想知道为什么我不能只指定数据库并停在那里。好吧,该项目的结构方式是我使用相同的程序根据正在访问的组织数据库切换连接,方法是使用组织 ID 从主数据库中获取连接字符串。我错过的是从主数据库中的连接 table 中获取组织数据库名称。

所以这是我为了得出这个结论而执行的测试用例:

  1. 创建两个数据库smu_teachers,smu_farmers;
  2. 正在创建 tables user_accounts 但每个数据库中的主键名称不同,即 对于 smu_teachers
   CREATE TABLE `user_accounts` (
         `user_id` int(11) NOT NULL AUTO_INCREMENT,
         `username` varchar(50) NOT NULL,
         `surname` varchar(50) NOT NULL,
         `first_name` varchar(50) DEFAULT NULL,
          PRIMARY KEY (`user_id`,`username`)
   ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

对于smu_farmers

   CREATE TABLE `user_accounts` (
       `user_identity` int(11) NOT NULL AUTO_INCREMENT,
       `username` varchar(50) NOT NULL,
       `surname` varchar(50) NOT NULL,
       `first_name` varchar(50) DEFAULT NULL,
       PRIMARY KEY (`user_identity`)
   ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
  1. 创建一个拥有任何以 smu_ 开头的数据库的所有权限的用户,即用户 smu_root
   GRANT ALL PRIVILEGES ON `smu_%`.* TO `smu_root`@`%`
  1. 创建一个只对一个数据库具有所有权限的用户,smu_teachers 即用户 smu_teachers_user
   GRANT ALL PRIVILEGES ON `smu_teachers`.* TO `smu_teachers_user`@`%`
  1. 运行用户smu_root:
  2. 的测试程序
@Test
public void getPrimaryKeys() throws Exception {
    DatabaseMetaData databaseMetaData = null;
    ResultSet rs = null;
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/smu_teachers_corp?" +
                    "autoReconnect=true&allowMultiQueries=true&useSSL=false&createDatabaseIfNotExist=false&allowPublicKeyRetrieval=true",
            "smu_root", "smu_root_password");
    try {
        databaseMetaData = connection.getMetaData();
        rs = databaseMetaData.getPrimaryKeys(null, null, "user_accounts");
        ResultSetMetaData resultSetMetaData = rs.getMetaData();
        while (rs.next()) {
            System.out.println(rs.getString("COLUMN_NAME"));
            for (int i = 1; i <= resultSetMetaData.getColumnCount(); i++) {
                System.out.println("Label: " + resultSetMetaData.getColumnLabel(i) + "  Value:" + rs.getString(i));
            }
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

输出:

user_identity
Label: TABLE_CAT  Value:smu_farmers
Label: TABLE_SCHEM  Value:null
Label: TABLE_NAME  Value:user_accounts
Label: COLUMN_NAME  Value:user_identity
Label: KEY_SEQ  Value:1
Label: PK_NAME  Value:PRIMARY
user_id
Label: TABLE_CAT  Value:smu_teachers
Label: TABLE_SCHEM  Value:null
Label: TABLE_NAME  Value:user_accounts
Label: COLUMN_NAME  Value:user_id
Label: KEY_SEQ  Value:1
Label: PK_NAME  Value:PRIMARY
username
Label: TABLE_CAT  Value:smu_teachers
Label: TABLE_SCHEM  Value:null
Label: TABLE_NAME  Value:user_accounts
Label: COLUMN_NAME  Value:username
Label: KEY_SEQ  Value:2
Label: PK_NAME  Value:PRIMARY
  1. 运行 使用用户 smu_root 测试程序,但指定数据库名称,例如smu_farmers 产量:
user_identity
Label: TABLE_CAT  Value:smu_farmers
Label: TABLE_SCHEM  Value:null
Label: TABLE_NAME  Value:user_accounts
Label: COLUMN_NAME  Value:user_identity
Label: KEY_SEQ  Value:1
Label: PK_NAME  Value:PRIMARY
  1. 运行 使用用户 smu_teachers 测试程序,同时指定和不指定数据库名称产生:
user_id
Label: TABLE_CAT  Value:smu_teachers
Label: TABLE_SCHEM  Value:null
Label: TABLE_NAME  Value:user_accounts
Label: COLUMN_NAME  Value:user_id
Label: KEY_SEQ  Value:1
Label: PK_NAME  Value:PRIMARY
username
Label: TABLE_CAT  Value:smu_teachers
Label: TABLE_SCHEM  Value:null
Label: TABLE_NAME  Value:user_accounts
Label: COLUMN_NAME  Value:username
Label: KEY_SEQ  Value:2
Label: PK_NAME  Value:PRIMARY

万一其他人遇到类似的问题,这可以帮助他们轻松判断自己做错了什么。