package com.splicemachine.tutorials.jdbc

import java.sql.DriverManager
import java.sql.Connection

/**
 *  Simple example of Establishes a connection with splice and executes statements
 */
object SampleScalaJDBC{

	def main(args: Array[String]) {

		// connect to the database named "splicedb" on the localhost
		val driver = "com.splicemachine.db.jdbc.ClientDriver"
		val dbUrl = "jdbc:splice://localhost:1527/splicedb;user=splice;password=admin"

		var connection:Connection = null

		try {

			// make the connection
			Class.forName(driver)
			connection = DriverManager.getConnection(dbUrl)

			// create the statement
			var statement = connection.createStatement()

			//Create a table
			statement.execute("CREATE TABLE MYTESTTABLE(a int, b varchar(30))");
			statement.close

			//Insert data into the table
			var pst = connection.prepareStatement("insert into MYTESTTABLE (a,b)  values (?,?)")

			pst.setInt (1, 1)
			pst.setString (2, "a")
			pst.executeUpdate()

			pst.clearParameters()
			pst.setInt (1, 2)
			pst.setString (2, "b")
			pst.executeUpdate()

			pst.clearParameters()
			pst.setInt (1, 3)
			pst.setString (2, "c")
			pst.executeUpdate()

			pst.clearParameters()
			pst.setInt (1, 4)
			pst.setString (2, "c")
			pst.executeUpdate()

			pst.clearParameters()
			pst.setInt (1, 5)
			pst.setString (2, "c")
			pst.executeUpdate()

			pst.close

			//Read the data
			statement = connection.createStatement()
			val resultSet = statement.executeQuery("select a, b from MYTESTTABLE")
			var counter =0

			while ( resultSet.next() ) {
				counter += 1
				val val_a = resultSet.getInt(1)
				val val_b = resultSet.getString(2)
				println("record=[" + counter + "] a=[" + val_a + "] b=[" +val_b + "]")
			}
			resultSet.close()
			statement.close()
		} catch {
			case ex : java.sql.SQLException => println("SQLException: "+ex)
		} finally {
			connection.close()
		}
	}

}