在spring r2dbc中创建表格

Question

我有一个 postgresql 数据库的 spring r2dbc 连接，并想创建一个表，

实际上等同于 SQL

CREATE TABLE IF NOT EXISTS name (id, bigint);

由于DatabaseClient似乎只支持select/insert，我如何做到这一点？

Answer 1

正如托马斯·安多尔夫在评论中所说

。执行（）. sql（）确实是正确的方法

在我的例子中，我需要在继续之前无限期地阻塞结果，所以我需要追加< code >。获取()。全部()。collectList()。block()；

Answer 2

您不需要使用DatabaseClient来创建您的表。所以当我面临和你一样的问题时，我做了类似下面的代码:

 fun postgresProcess(config: PostgresConfig): PostgresProcess {
        val runtime = PostgresStarter.getDefaultInstance()
        val exec = runtime.prepare(config)
        val postgres = exec.start()
        // connecting to a running Postgres and feeding up the database
        val conn = DriverManager.getConnection("jdbc:postgresql://$host:$port/$database", username, password)
        conn.createStatement().execute("CREATE TABLE customer ( id SERIAL PRIMARY KEY, firstname VARCHAR(100) NOT NULL, lastname VARCHAR(100) NOT NULL);")
        return postgres
    }

一开始，你可以做这样的事情，之后你可以使用数据库客户端。

我记得尝试flyway没有成功。我本来想使用数据库客户端。我的回购github上的更多代码