internal.xsltc.compiler.util.IntType import org.apache.spark.sql.types._ import org.apache.spark.sql.{Row, SparkSession}import org.apache.spark.sql.SQLContext import org.apache.spark.{SparkConf, SparkContext} object jdbc {def main(args: Array[String]): Unit = {val conf = new SparkConf().setAppName("JdbcOperation").setMaster("local")val sc = new SparkContext(conf)val sqlContext = new SQLContext(sc)...
步骤：1）MySQL的驱动2）Connection 重量级的获取过程。可以使用POOL优化3）Statement 执行的类4）ResultSet 结果的封装5）Close 在pom中添加scala、hadoop、Mysql驱动依赖包：<properties> <scala.version>2.11.8</scala.version> <hadoop.version>2.6.5</hadoop.version></properties> <dependency> <groupId>org.scala-lang</groupId> <artifactId>scala-library</artifactId> <version>${scala.version}<...
修改级联驱动，scala是Sources，resources是Resources配置文件目录： ? ? 创建配置文件，及文件内容： ?db.default.driver="com.mysql.jdbc.Driver"db.default.url="jdbc:mysql://hadoop001:3306/ruoze_g6"db.default.user="root"db.default.password="123456" 3）代码：package com.ruozeimport scalikejdbc._import scalikejdbc.config._object ScalalikeJdbc{ def main(args:Array[String]):Unit = { //默认加...
package com.biimport java.sql.{Connection, DriverManager, Timestamp} import java.util.Calendar/*** Created by xxx on 2017/6/28.*/ object MySqlConn {// for test envval mysqlConfTest = collection.mutable.Map("driver" -> "com.mysql.jdbc.Driver","url" -> "jdbc:mysql://192.168.18.106:3306/rpt","username" -> "test","password" -> "test")// for prod envval mysqlConfProd = collection.mutable.Map("driver" -...