import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.Reader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import org.apache.ibatis.jdbc.ScriptRunner;
public class RunningScripts {
public static void main(String args[]) throws Exception {
//Registering the Driver
DriverManager.registerDriver(new com.mysql.jdbc.Driver());
//Getting the connection
String mysqlUrl = "jdbc:mysql://localhost/talakai_noppi";
Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
System.out.println("Connection established......");
//Initialize the script runner
ScriptRunner sr = new ScriptRunner(con);
//Creating a reader object
Reader reader = new BufferedReader(new FileReader("E:sampleScript.sql"));
//Running the script
sr.runScript(reader);
}
}
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.sql.SQLException;
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.Statement;
public class Database {
private static final String DRIVER_NAME = "com.mysql.jdbc.Driver";
static
{
try
{
Class.forName(DRIVER_NAME).newInstance();
System.out.println("*** Driver loaded");
}
catch(Exception e)
{
System.out.println("*** Error : "+e.toString());
System.out.println("*** ");
System.out.println("*** Error : ");
e.printStackTrace();
}
}
private static final String URL = "jdbc:mysql://localhost/mydatabase";
private static final String USER = "root";
private static final String PASSWORD = "password";
private static String INSTRUCTIONS = new String();
public static Connection getConnection() throws SQLException
{
return DriverManager.getConnection(URL, USER, PASSWORD);
}
public static void resetDatabase() throws SQLException
{
String s = new String();
StringBuffer sb = new StringBuffer();
try
{
FileReader fr = new FileReader(new File("mySQLFile.sql"));
// be sure to not have line starting with "--" or "/*" or any other non aplhabetical character
BufferedReader br = new BufferedReader(fr);
while((s = br.readLine()) != null)
{
sb.append(s);
}
br.close();
// here is our splitter ! We use ";" as a delimiter for each request
// then we are sure to have well formed statements
String[] inst = sb.toString().split(";");
Connection c = Database.getConnection();
Statement st = c.createStatement();
for(int i = 0; i<inst.length; i++)
{
// we ensure that there is no spaces before or after the request string
// in order to not execute empty statements
if(!inst[i].trim().equals(""))
{
st.executeUpdate(inst[i]);
System.out.println(">>"+inst[i]);
}
}
}
catch(Exception e)
{
System.out.println("*** Error : "+e.toString());
System.out.println("*** ");
System.out.println("*** Error : ");
e.printStackTrace();
System.out.println("################################################");
System.out.println(sb.toString());
}
}