import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

Class.forName(“com.mysql.jdbc.Driver”).newInstance()
val DB_URL = “jdbc:mysql://yourhost.com/yourdatabase?user=SomeUsername&password=SomePassword”
csqlc.setKeyspace(“analytics”)

csqlc.read.format(“jdbc”).options(
  Map(“driver” -> “com.mysql.jdbc.Driver”,
  “url” -> DB_URL,
  “dbtable” -> “yourdatabase.users”)
).load().registerTempTable(“analytics_users”)