因為企業上使用postgre timescale數據庫來保存實時數據，所以在做spark任務時需要去連接postgre數據庫，demo如下：

val conn_str = "jdbc:postgresql://ip:port/db"val conn: Connection = DriverManager.getConnection(conn_str, "用戶名", "密碼")try {// Configure to be Read Onlyval statement = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY)// Execute Queryval rs = statement.executeQuery("SELECT * FROM spark_table")// Iterate Over ResultSetwhile (rs.next) {println(rs.getString("xxx"))}}finally {conn.close}

pom文件中引入如下依賴：

<dependency><groupId>org.postgresql</groupId><artifactId>postgresql</artifactId><version>42.1.1</version></dependency>

總結

以上是生活随笔為你收集整理的scala连接postgre数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。