scala tableEnv设置一下连接pgsql超时时间

在 Scala Flink 中使用 Table API 和 SQL 连接 PostgreSQL 数据库并设置连接超时时间，可以使用以下代码：

import org.apache.flink.table.api.EnvironmentSettings
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment
import java.util.Properties

val settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()
val tableEnv = StreamTableEnvironment.create(streamExecutionEnvironment, settings)

val url = "jdbc:postgresql://localhost:5432/mydb"
val user = "myuser"
val password = "mypassword"

val connectionProperties = new Properties()
connectionProperties.setProperty("user", user)
connectionProperties.setProperty("password", password)
connectionProperties.setProperty("connectTimeout", "5000") // 设置连接超时时间为 5 秒

tableEnv.getConfig().getConfiguration().setString("table.exec.source.pgsql.connection-url", url)
tableEnv.getConfig().getConfiguration().setProperties("table.exec.source.pgsql.connection-properties", connectionProperties)

在以上代码中，`connectionProperties.setProperty("connectTimeout", "5000")` 设置了连接超时时间为 5 秒。你可以根据自己的需求修改超时时间，单位是毫秒。同时，`tableEnv.getConfig().getConfiguration().setString("table.exec.source.pgsql.connection-url", url)` 设置了连接 URL，`tableEnv.getConfig().getConfiguration().setProperties("table.exec.source.pgsql.connection-properties", connectionProperties)` 设置了连接属性。请注意，这里的 `table.exec.source.pgsql` 是针对 PostgreSQL 数据库的，如果你使用其他数据库，需要根据具体情况修改。