亚洲乱码国产乱码精品精98午夜,一本大道av日日躁夜夜躁,在线播放一区二区三区

1、定義數(shù)據(jù)庫(kù)連接

01package com.web.dataSource
02  
03import com.alibaba.druid.pool.DruidDataSource
04  
05object MySqlDataSource {
06  
07 val driver = "com.mysql.jdbc.Driver"
08 val url = "jdbc:mysql://127.0.0.1:3306"
09 val username = "root"
10 val password = "root"
11  
12 val connectionPool = new DruidDataSource()
13 connectionPool.setUsername(username)
14 connectionPool.setPassword(password)
15 connectionPool.setDriverClassName(driver)
16 connectionPool.setUrl(url)
17 connectionPool.setValidationQuery("select 1")
18 connectionPool.setInitialSize(15)
19 connectionPool.setMinIdle(10)
20 connectionPool.setMaxActive(100)
21 connectionPool.setRemoveAbandoned(true)
22 connectionPool.setRemoveAbandonedTimeoutMillis(180000)
23 connectionPool.setMaxWait(5000)
24 connectionPool.setTestOnBorrow(false)
25 connectionPool.setTestOnReturn(false)
26  
27}

2、執(zhí)行查詢(xún)

01def getOptions(uid:Int) ={
02  
03 val connection = MySqlDataSource.connectionPool.getConnection
04 var sql = 
05      s""" select username,password,sex
06      |from user 
07  
08      |where uid = ?
09  
10      """.stripMargin
11  
12var stmt = connection.prepareStatement(sql)
13  
14stmt.setInt(1, uid)
15  
16var resultSet = stmt.executeQuery()
17  
18var resultListMap = List[Map[String,String]]()
19  
20//獲取結(jié)果
21  
22while(resultSet.next()){
23  
24resultListMap = resultListMap :+ Map(
25  
26                               "username"->resultSet.getString("username"),
27  
28                               "password"->resultSet.getString("password"),
29  
30                               "sex"->resultSet.getInt("sex"),
31  
32                              )
33  
34}
35  
36//關(guān)閉連接
37  
38stmt.close()
39  
40connection .close()
41  
42//返回結(jié)果
43  
44resultListMap
45  
46}

3、插入數(shù)據(jù)

01object UpdateLocation {
02 
03 def main(args: Array[String]): Unit = {
04  val conf = new SparkConf().setAppName("UpdateLocation").setMaster("local[2]")
05  val sc = new SparkContext(conf)
06  var conn: Connection = null
07  var ps: PreparedStatement = null
08  try {
09   val sql = "INSERT INTO location_info(location,accesse_date,counts) VALUES (?,?,?)"
10   conn = DriverManager.getConnection("jdbc:mysql://192.168.126.31:3306/sparkdatabase?useUnicode=true&characterEncoding=utf-8", "root", "Zhm@818919")
11   ps = conn.prepareStatement(sql)
12   ps.setString(1, "深圳")
13   ps.setString(2, "2018-7-2")
14   ps.setInt(3, 122)
15   ps.execute()
16  } catch {
17   case e: Exception => println("myException")
18  } finally {
19   if (conn != null) {
20    conn.close()
21   }
22   if (ps != null) {
23    ps.close()
24   }
25  }
26  sc.stop()
27 }
28}

4、刪除操作

01object DeleteLocation {
02 
03 def main(args: Array[String]): Unit = {
04  val conf = new SparkConf().setAppName("UpdateLocation").setMaster("local[2]")
05  val sc = new SparkContext(conf)
06  var conn: Connection = null
07  var ps: PreparedStatement = null
08  try {
09   val sql = "delete from location_info where location = ?"
10   conn = DriverManager.getConnection("jdbc:mysql://192.168.126.31:3306/sparkdatabase?useUnicode=true&characterEncoding=utf-8", "root", "Zhm@818919")
11   ps = conn.prepareStatement(sql)
12   ps.setString(1, "深圳")
13   ps.execute()
14  } catch {
15   case e: Exception => println("myException")
16  } finally {
17   if (conn != null) {
18    conn.close()
19   }
20   if (ps != null) {
21    ps.close()
22   }
23  }
24  sc.stop()
25 }
26}

5、更新操作

01object InsertLocation {
02 
03 def main(args: Array[String]): Unit = {
04  val conf = new SparkConf().setAppName("UpdateLocation").setMaster("local[2]")
05  val sc = new SparkContext(conf)
06  var conn: Connection = null
07  var ps: PreparedStatement = null
08  try {
09   val sql = "update location_info set location=? where id = ?";
10   conn = DriverManager.getConnection("jdbc:mysql://192.168.126.31:3306/sparkdatabase?useUnicode=true&characterEncoding=utf-8", "root", "Zhm@818919")
11   ps = conn.prepareStatement(sql)
12   ps.setString(1, "深圳")
13   ps.setInt(2,26)
14   ps.execute()
15  } catch {
16   case e: Exception => println("myException")
17  } finally {
18   if (conn != null) {
19    conn.close()
20   }
21   if (ps != null) {
22    ps.close()
23   }
24  }
25  sc.stop()
26 }
27}