trunk/tools/mySQLConnect.java

package tools; 

import java.sql.*;
import java.io.*;
import java.util.*;

public class mySQLConnect 
{
    private String host="", port="", user="", password="", dbname=""; 
    private String driverName = "com.mysql.jdbc.Driver"; 

    public void setDriverName( String xDriver) { driverName = xDriver; }
    public String getDriverName() { return driverName; }

    public void setHost( String xHost) { host = xHost; }
    public String getHost() { return host; }
    
    public void setPort( String xPort) { port = xPort; }
    public String getPort() { return port; }

    public void setUser( String xUser) { user = xUser; }
    public String getUser() { return user; }

    public void setPassword( String xPW) { password = xPW; }
    public String getPassword() { return password; }

    public void setDB( String xDB) { dbname = xDB; }
    public String getDB() { return dbname; }

    public mySQLConnect() {

        loadSQLDriver();
        
    }

    /** this function loads the SQL driver specified by driverName */ 
    public void loadSQLDriver() {
        try {
            // The newInstance() call is a work around for some broken Java implementations
            //System.out.print("Loading "+driverName +" ... "); 
            Class.forName(driverName).newInstance(); 
            //System.out.println("done."); 
        } 
        catch (Exception E) {
            System.out.println("\nUnable to load SQL-driver "+driverName);
            E.printStackTrace();
        } // end catch 
    }// end loadSQLDriver 
    
    /** closes the current connection to the SQL-database */ 
    public void closeConnection( Connection C ) {
        try {
            C.close(); 
        } catch (SQLException E) {
            System.out.println("SQLException:\t" + E.getMessage());
            System.out.println("SQLState:\t" + E.getSQLState());
            System.out.println("VendorError: \t" + E.getErrorCode());
        } // end try/catch connection 
    } // end closeConnection 

    public Connection openConnection() { 
        // open a connection with the parameters retrieved to the database <dbname> 
        Connection Conn=null;
        String connector = "";
        try {
            Class.forName( driverName).newInstance();        
            try {
                // System.out.println("// open Connection()");
                // System.out.println("host "+host);
                // System.out.println("port "+port);
                // System.out.println("dbname "+dbname);
                // System.out.println("user "+user);
                // System.out.println("password "+password);
                
                if (!password.equals("")) {
                    connector = "jdbc:mysql://"+host+port+"/"+dbname+"?user="+user+"&password="+password+"&allowMultiQueries=true";
                } else {
                    connector = "jdbc:mysql://"+host+port+"/"+dbname+"?user="+user+"&allowMultiQueries=true";
                }
                //System.out.println("Opening a connection to "+connector); 
                Conn = DriverManager.getConnection( connector);
          } catch (SQLException E) {
                System.out.println("SQLException: " + E.getMessage());
                System.out.println("SQLState:     " + E.getSQLState());
                System.out.println("VendorError:  " + E.getErrorCode());
            } // end try/catch connection 
        } // end try load Driver  
        catch (Exception E) {
            System.err.println("Unable to load driver.");
            E.printStackTrace();
        } // end catch load driver
        return Conn; 
    } // end openConnection()


    public void readConnectionFile( String connFile) {
        // reads the values of the connFile into the static variables; 
        String homedir = System.getProperty("user.home"); 
        // System.out.println("HOME@ "+homedir); // HOME=/home/lappe
        if( connFile.length()==0) { // no file was specified
            connFile=homedir+"/.my.cnf"; // assume default configuration file 
        } // end if
        // else the location of the connection file was given 

        //System.out.println("Reading settings from file "+connFile);
        // Open the configuration file
        FileReader theFile = null;
        BufferedReader fileIn = null;
        StringTokenizer str;
        String item, oneLine; 
        
        // list the entries in the file and decompose them 
        try {
            File inputFile = new File(connFile);
            theFile = new FileReader(inputFile); // open the File
            fileIn = new BufferedReader( theFile); // open BufferedReader 
            while ((oneLine = fileIn.readLine() ) != null ) {
                // Write the line at hand to stdout, just for testing purposes 
                // System.out.println("["+oneLine+"]");
                // Construct a stringTokenizer for the line that we read with : delimited
                str = new StringTokenizer( oneLine, " ="); // true sets returnDelimiters flag 
                while ( str.hasMoreTokens()) {
                    item = str.nextToken();
                    // System.out.println("item:"+item);
                    if( item.equals("host")) {
                        host=str.nextToken();
                        // System.out.println("host:"+host);
                        break; 
                    } // end if host 
                    if( item.equals("port")) {
                        port=":"+str.nextToken();
                        // System.out.println("port:"+port);
                        break; 
                    } // end if port
                    if( item.equals("user")) {
                        user=str.nextToken();
                        // System.out.println("user:"+user);
                        break; 
                    } // end if password 
                    if( item.equals("password")) {
                        password=str.nextToken();
                        // System.out.println("password:"+password);
                        break; 
                    } // end if password
                    if( item.equals("database")) {
                        dbname=str.nextToken();
                        // System.out.println("database:"+dbname);
                        break; 
                    } // end if password 
                    
                } // next token in this line 
            } // next line in the file 
        } // end try opening the file 
        catch ( Exception e ) { System.out.println( e); }  
        
        try { // closing the file
            if( fileIn != null) fileIn.close();
            if( theFile != null) theFile.close();
        } catch ( Exception e ) { System.out.println( e); }
        
    } // end class readConnectionFile

} // end class mySQLconnect 
Revision:	492
Committed:	Wed Jan 2 13:18:57 2008 UTC (16 years, 10 months ago) by duarte
File size:	5567 byte(s)
Log Message:	Copied the aglappe-jung branch into trunk.
Line	File contents
1	package tools;
2
3	import java.sql.*;
4	import java.io.*;
5	import java.util.*;
6
7	public class mySQLConnect
8	{
9	private String host="", port="", user="", password="", dbname="";
10	private String driverName = "com.mysql.jdbc.Driver";
11
12	public void setDriverName( String xDriver) { driverName = xDriver; }
13	public String getDriverName() { return driverName; }
14
15	public void setHost( String xHost) { host = xHost; }
16	public String getHost() { return host; }
17
18	public void setPort( String xPort) { port = xPort; }
19	public String getPort() { return port; }
20
21	public void setUser( String xUser) { user = xUser; }
22	public String getUser() { return user; }
23
24	public void setPassword( String xPW) { password = xPW; }
25	public String getPassword() { return password; }
26
27	public void setDB( String xDB) { dbname = xDB; }
28	public String getDB() { return dbname; }
29
30	public mySQLConnect() {
31
32	loadSQLDriver();
33
34	}
35
36	/** this function loads the SQL driver specified by driverName */
37	public void loadSQLDriver() {
38	try {
39	// The newInstance() call is a work around for some broken Java implementations
40	//System.out.print("Loading "+driverName +" ... ");
41	Class.forName(driverName).newInstance();
42	//System.out.println("done.");
43	}
44	catch (Exception E) {
45	System.out.println("\nUnable to load SQL-driver "+driverName);
46	E.printStackTrace();
47	} // end catch
48	}// end loadSQLDriver
49
50	/** closes the current connection to the SQL-database */
51	public void closeConnection( Connection C ) {
52	try {
53	C.close();
54	} catch (SQLException E) {
55	System.out.println("SQLException:\t" + E.getMessage());
56	System.out.println("SQLState:\t" + E.getSQLState());
57	System.out.println("VendorError: \t" + E.getErrorCode());
58	} // end try/catch connection
59	} // end closeConnection
60
61	public Connection openConnection() {
62	// open a connection with the parameters retrieved to the database <dbname>
63	Connection Conn=null;
64	String connector = "";
65	try {
66	Class.forName( driverName).newInstance();
67	try {
68	// System.out.println("// open Connection()");
69	// System.out.println("host "+host);
70	// System.out.println("port "+port);
71	// System.out.println("dbname "+dbname);
72	// System.out.println("user "+user);
73	// System.out.println("password "+password);
74
75	if (!password.equals("")) {
76	connector = "jdbc:mysql://"+host+port+"/"+dbname+"?user="+user+"&password="+password+"&allowMultiQueries=true";
77	} else {
78	connector = "jdbc:mysql://"+host+port+"/"+dbname+"?user="+user+"&allowMultiQueries=true";
79	}
80	//System.out.println("Opening a connection to "+connector);
81	Conn = DriverManager.getConnection( connector);
82	} catch (SQLException E) {
83	System.out.println("SQLException: " + E.getMessage());
84	System.out.println("SQLState: " + E.getSQLState());
85	System.out.println("VendorError: " + E.getErrorCode());
86	} // end try/catch connection
87	} // end try load Driver
88	catch (Exception E) {
89	System.err.println("Unable to load driver.");
90	E.printStackTrace();
91	} // end catch load driver
92	return Conn;
93	} // end openConnection()
94
95
96	public void readConnectionFile( String connFile) {
97	// reads the values of the connFile into the static variables;
98	String homedir = System.getProperty("user.home");
99	// System.out.println("HOME@ "+homedir); // HOME=/home/lappe
100	if( connFile.length()==0) { // no file was specified
101	connFile=homedir+"/.my.cnf"; // assume default configuration file
102	} // end if
103	// else the location of the connection file was given
104
105	//System.out.println("Reading settings from file "+connFile);
106	// Open the configuration file
107	FileReader theFile = null;
108	BufferedReader fileIn = null;
109	StringTokenizer str;
110	String item, oneLine;
111
112	// list the entries in the file and decompose them
113	try {
114	File inputFile = new File(connFile);
115	theFile = new FileReader(inputFile); // open the File
116	fileIn = new BufferedReader( theFile); // open BufferedReader
117	while ((oneLine = fileIn.readLine() ) != null ) {
118	// Write the line at hand to stdout, just for testing purposes
119	// System.out.println("["+oneLine+"]");
120	// Construct a stringTokenizer for the line that we read with : delimited
121	str = new StringTokenizer( oneLine, " ="); // true sets returnDelimiters flag
122	while ( str.hasMoreTokens()) {
123	item = str.nextToken();
124	// System.out.println("item:"+item);
125	if( item.equals("host")) {
126	host=str.nextToken();
127	// System.out.println("host:"+host);
128	break;
129	} // end if host
130	if( item.equals("port")) {
131	port=":"+str.nextToken();
132	// System.out.println("port:"+port);
133	break;
134	} // end if port
135	if( item.equals("user")) {
136	user=str.nextToken();
137	// System.out.println("user:"+user);
138	break;
139	} // end if password
140	if( item.equals("password")) {
141	password=str.nextToken();
142	// System.out.println("password:"+password);
143	break;
144	} // end if password
145	if( item.equals("database")) {
146	dbname=str.nextToken();
147	// System.out.println("database:"+dbname);
148	break;
149	} // end if password
150
151	} // next token in this line
152	} // next line in the file
153	} // end try opening the file
154	catch ( Exception e ) { System.out.println( e); }
155
156	try { // closing the file
157	if( fileIn != null) fileIn.close();
158	if( theFile != null) theFile.close();
159	} catch ( Exception e ) { System.out.println( e); }
160
161	} // end class readConnectionFile
162
163	} // end class mySQLconnect