scala flink 连接pgsql 设置一下连接超时时间
时间: 2023-08-09 10:06:20 浏览: 141
flink-connector-doris 1.0.0
在 Scala Flink 中连接 PostgreSQL 数据库并设置连接超时时间,可以使用以下代码:
```scala
import java.sql.{Connection, DriverManager}
val url = "jdbc:postgresql://localhost:5432/mydb"
val user = "myuser"
val password = "mypassword"
val connectionProperties = new java.util.Properties()
connectionProperties.setProperty("user", user)
connectionProperties.setProperty("password", password)
connectionProperties.setProperty("connectTimeout", "5000") // 设置连接超时时间为 5 秒
val conn: Connection = DriverManager.getConnection(url, connectionProperties)
```
在以上代码中,`connectionProperties.setProperty("connectTimeout", "5000")` 设置了连接超时时间为 5 秒。你可以根据自己的需求修改超时时间,单位是毫秒。
阅读全文