package org.apache.spark.sql.sourcesimport org.apache.spark.SparkContextimport java.sql.{ResultSet, DriverManager}import org.apache.spark.rdd.JdbcRDD/** * @author luogankun * Created by spark on 14-12-25. */object JdbcTest extends  App{    val sc = new SparkContext("local[2]", "demo")    def getConnection() = {      Class.forName("com.mysql.jdbc.Driver").newInstance()      DriverManager.getConnection("jdbc:mysql://hadoop000:3306/hive", "root", "root")    }    def flatValue(result: ResultSet) = {      (result.getInt("TBL_ID"), result.getString("TBL_NAME"))    }    //select * from TBLS WHERE TBL_ID>=1 AND TBL_ID<=10    val data = http://www.mamicode.com/new JdbcRDD(      sc,      getConnection,      "select * from TBLS where TBL_ID >= ? and TBL_ID <= ?",      1,      10,      2,      flatValue    )    println(data.collect().toList)    sc.stop}