因?yàn)槠髽I(yè)上使用postgre timescale數(shù)據(jù)庫(kù)來(lái)保存實(shí)時(shí)數(shù)據(jù)，所以在做spark任務(wù)時(shí)需要去連接postgre數(shù)據(jù)庫(kù)，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>

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。