scala连接postgre数据库

因为企业上使用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数据库相关推荐

Scala连接mongodb数据库
mongodb是一种面向文档的数据库,Scala是一种函数式编程语言,由于项目的关系,需要使用Scala连接mongodb数据库.下面介绍具体的方法. 就像Java连接MySQL数据库需要JDBC一样 ...
scala连接mysql数据库
pom依赖: <dependency><groupId>mysql</groupId><artifactId>mysql-connector-java& ...
centos7下载spark连接mysql数据库提取数据(pyspark,Scala,python独立执行)
原文连接: http://dblab.xmu.edu.cn/blog/1724-2/ 原文连接:https://mapr.com/support/s/article/PySpark-to-MySQL- ...
Django连接postgresql数据库
配置前的基本情况说明: win7 +python2.7.3+PostgreSQL9.22+ Django1.4.3 psycopg2-2.4.6.win32-py2.7-pg9.2.2-release ...
XXL-Job 适配 Postgre 数据库的完整流程
背景开源任务调度框架 XXL-Job 默认是基于 MySQL 数据库开发的,好在它是使用了 MyBatis ,要支持其他数据库,需要改 Mapping 映射文件,建表语句换成其他数据库的. 主要差异 ...
scala mysql bit_Scala连接mysql数据库
scala 连接mysql 还是采用原来的jdbc驱动.废话不多说,直接上代码. 说明:scala 连接本地mysql里面一个ry-vue的数据库,并且查询sys_user表,遍历输出前4列的数据. ...
scala 连接oracle_一分钟教你学会用java连接Oracle数据库
package java_jdbc; //java连接Oracle数据库 import java.sql.Connection; import java.sql.DriverManager; impo ...
Entity Freamwork 6连接PostgreSql数据库
原文 Entity Freamwork 6连接PostgreSql数据库开发环境 VS 2015 Update 1 Postgre Sql 9.4 使用过程 1.使用Nuget在项目中添加对E ...
java编译POSTGRESQL_Java连接PostgreSQL数据库（安装环境 + 简易测试代码）
--[楼主比较啰嗦, 会列出几个异常情况以供参考]-- 1, 安装环境 1.0 Win7 32位 1.2 编译器: Spring Tool Suite 3.7.1 官网下载地址:http://sp ...

scala连接postgre数据库

scala连接postgre数据库相关推荐

最新文章

热门文章