码迷,mamicode.com
首页 > 数据库 > 详细

在scala中访问postgresql(使用sbt)

时间:2015-06-20 17:11:39      阅读:192      评论:0      收藏:0      [点我收藏+]

标签:scala   postgresql   sbt   

默认已经安装了scala和SBT,并且对sbt有基本了解,知道怎样用sbt建立一个工程。

添加依赖

要在scala中使用postgresql数据库,需要导入postgresql驱动相关的库文件,postgresql的库文件,可以去其官网上下载,一定要下载和你的scala、Jdk对应的版本。现在有两种途径可以在scala工程编译时添加这个postgresql库:
1. 自己下载这个依赖库,是一个jar文件,把这个文件放到sbt工程目录下的lib\下
2. 不用自己下载这个依赖库,在build.sbt中声明依赖这个文件,在编译的过程中sbt会自动下载这个库文件,并添加这个库。在sbt的帮助文件中告诉了如何添加这个依赖的语法

libraryDependencies += groupID % artifactID % revision % configuration

那么现在问题来了,我只知道我需要postgresql,哪里知道groupID、artifactID这些东东是什么,给大家一个汇合了许多库文件的网站, 在这个网站中搜索postgresql,在搜索结果中就给出了postgresql驱动库的groupID、artifactID这些信息
技术分享
根据这些信息,就知道应该在build.sbt文件中这么写依赖项了

libraryDependencies += “org.postgresql” % “postgresql” % “9.4-1201-jdbc41” % “provided”

整个build.sbt就是

name := "Task3"
version := "1.0"
scalaVersion := "2.10.5"
libraryDependencies += "org.postgresql" % "postgresql" % "9.4-1201-jdbc41" % "provided"

这么写了之后,编译应该不会出问题了,使用sbt package可以讲工程打包成jar。但是仍然不能运行,运行会出现class not found之类的错误。因为还需要把postgresql依赖库文件的位置添加到Java的classpath中,这样运行就不会出问题了。

使用postgresql

基本查询

val conn_str = "jdbc:postgresql://IP地址:端口号/数据库名称"
classOf[com.mysql.jdbc.Driver]  
// 使用上一句可能会有warning,因为这是一个表达式,可以换成下面的
// Class.forName("org.postgresql.Driver").newInstance
val conn = DriverManager.getConnection(conn_str, "用户名称", "密码")
val conn = DriverManager.getConnection(conn_str)
try {
      // Configure to be Read Only
      val statement = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY)
     // Execute Query
      val rs = statement.executeQuery("SELECT quote FROM quotes LIMIT 5")
     // Iterate Over ResultSet
     while (rs.next) {
       println(rs.getString("quote"))
     }
  }
  finally {
      conn.close  
  }

表操作(Insert,update,delete)

  val dbc = "jdbc:mysql://localhost:3306/DBNAME?user=DBUSER&password=DBPWD"
  classOf[com.mysql.jdbc.Driver]
  // 这是另外一种写法,把用户名和密码都写在一起
  val conn = DriverManager.getConnection(dbc)
  val statement = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_UPDATABLE)

  // do database insert
  try {
    val prep = conn.prepareStatement("INSERT INTO quotes (quote, author) VALUES (?, ?) ")
    prep.setString(1, "Nothing great was ever achieved without enthusiasm.")
    prep.setString(2, "Ralph Waldo Emerson")
    prep.executeUpdate
  }
  finally {
    conn.close
  }

在scala中访问postgresql(使用sbt)

标签:scala   postgresql   sbt   

原文地址:http://blog.csdn.net/whoispo/article/details/46573713

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!