scala通過JDBC方式操作mysql (需要加載 mysql-connector-java 驅動)
maven依賴：
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.45</version></dependency>
一、scala連接mysql（jdbc方式）
import java.sql.{ Connection, DriverManager }object JBJDBC extends App {// 訪問本地MySQL服務器，通過3306端口訪問mysql數據庫val url = "jdbc:mysql://localhost:3306/datassets_4300?useUnicode=true&characterEncoding=utf-8&useSSL=false"//驅動名稱val driver = "com.mysql.jdbc.Driver"//用戶名val username = "root"//密碼val password = "123456"//初始化數據連接var connection: Connection = _try {//注冊DriverClass.forName(driver)//得到連接connection = DriverManager.getConnection(url, username, password)val statement = connection.createStatement}}
}
前提：在我本地有一個Persion表，包括id和name兩個字段
二、查詢操作
通過connection.createStatement進行數據的查詢操作
val statement = connection.createStatement//執行查詢語句，并返回結果val rs = statement.executeQuery("SELECT id,name FROM persons")//打印返回結果while (rs.next) {val id = rs.getString("id")val name = rs.getString("name")// println(name+"\t"+num)println("id = %s ,name = %s".format(id, name))}println("查詢數據完成！")
三、增刪改
val statement = connection.createStatement//執行查詢語句，并返回結果val rs = statement.executeUpdate("SQL語句")
