JDBC querys from directory

[Koen Desmedt]

Hello Forum.

I am making a java program that workt with JDBC to contact a database and send querys from a directory to it and get the result back.
How can i select all the querys that i have in a directory?
Because now i think i only select test.sql
Also the output has to be saved in a cvs file. I don't know how i should do that, is it just create_new???


Btw if you have any remarks on the code please share

This is the code:

import java.io.BufferedReader;    
import java.io.File;  
import java.io.FileReader;
import java.io.FileWriter;
import java.io.Writer;
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:jtds:sqlserver://;DatabaseName=";  
    private static final String USER = "root";  
    private static final String PASSWORD = "root";  
    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("test.sql"));  
 
  
            BufferedReader br = new BufferedReader(fr);  
  
            while((s = br.readLine()) != null)  
            {  
                sb.append(s);  
            }  
            br.close();  
  
         
            String[] inst = sb.toString().split(";");  
  
            Connection c = Database.getConnection();  
            Statement st = c.createStatement();  
   
            for(int i = 0; i<inst.length; i++)  
            {  
 
                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());  
        }  
  
    }  

}