如何用PyQt通过单查询在PostgreSQL中创建含表的数据库模式？

问题根源 #

QSqlQuery默认不支持一次性执行多条SQL语句（PostgreSQL的QPSQL驱动默认禁用了多语句执行），所以你写的包含CREATE SCHEMA、SET search_path、CREATE TABLE的复合语句，只有第一条会被执行，后续语句直接被忽略。

解决方案：拆分语句单独执行 #

将每个SQL操作拆分为独立的exec_()调用，同时增加数据库连接和语句执行的错误检查，确保每一步都成功：

# 初始化数据库连接
db = QSqlDatabase.addDatabase("QPSQL")
db.setHostName("localhost")
db.setDatabaseName("my_db")
db.setUserName("postgres")
db.setPassword("0000")

# 检查连接是否成功
if not db.open():
    print(f"数据库连接失败: {db.lastError().databaseText()}")
else:
    my_schema = "schema1"
    query = QSqlQuery(db)  # 绑定数据库连接，避免默认连接的潜在问题

    # 1. 创建模式
    if not query.exec_(f"CREATE SCHEMA IF NOT EXISTS {my_schema};"):
        print(f"创建模式失败: {query.lastError().databaseText()}")
    else:
        # 2. 设置搜索路径到目标模式
        if not query.exec_(f"SET search_path TO {my_schema};"):
            print(f"设置搜索路径失败: {query.lastError().databaseText()}")
        else:
            # 3. 创建数据表
            create_table_sql = """
            CREATE TABLE pt (
                id SERIAL PRIMARY KEY NOT NULL,
                name VARCHAR(5),
                geom geometry(Point, 2532)
            );
            """
            if query.exec_(create_table_sql):
                print("模式和数据表创建成功！")
            else:
                print(f"创建数据表失败: {query.lastError().databaseText()}")

    # 关闭数据库连接
    db.close()

额外说明 #

• 每次执行exec_()后检查返回值，能快速定位哪一步出了问题
• 初始化QSqlQuery时绑定数据库连接（QSqlQuery(db)），避免依赖全局默认连接的不确定性
• 如果一定要用多语句执行，可以尝试开启QPSQL驱动的multiStatement属性，但这种方式风险较高（易引发SQL注入，错误排查困难），不推荐：

  db.setConnectOptions("options='-c client_min_messages=warning' -c statement_timeout=1000;multiStatement=true")
  

内容的提问来源于stack exchange，提问作者Fahd Jerbi