trunk/tools/mySQLConnect.java

package tools; 

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