27 Mayıs 2007 Pazar

Database Connection Class

A class to make a mySQL database connection using java
----------------------------------------------


/*
* Created on 02 August 2005 Tuesday
*
*/


/**
* @author ozkan sari
*/

import java.sql.*;
import java.sql.DriverManager;


/**
*
*/
public class DatabaseConn {

private static Connection conn ;
private static final String DBconnName = "my_db/localhost";

public DatabaseConn()
{
String serverName = "localhost";
String dbName = "my_db";
String userName = "root";
String password = "my_pw";

String url = "jdbc:mysql://"+ serverName +"/"+ dbName ;

makeDbConnection( url, userName, password );
}

public Connection getConnection( )
{
return conn;
}


/* ***********************************************************************************************/
/* -- makeDbConnection() FUNCTION ---------------------------------------------------------------*/
/* ***********************************************************************************************/

public Connection makeDbConnection( String databaseURL, String user, String pw ) {

try {
// load database driver class
//Class.forName("org.gjt.mm.mysql.Driver").newInstance();
Class.forName("com.mysql.jdbc.Driver").newInstance();

if( user == null || pw==null ) {
user = "root";
pw = "";
}

// connect to database
conn = DriverManager.getConnection(databaseURL , user, pw);

System.out.println("->Database connection established");

return conn;
}
// detect problems loading database driver
catch ( ClassNotFoundException classNotFound ) {
classNotFound.getMessage();
System.out.println("->DB PROBLEM: Cannot load DB driver");
}
// detect database access problems
catch ( SQLException sqlexception ) {
sqlexception.getMessage();
System.out.println("->DB PROBLEM: Cannot access DB");
}
// detect other problems
catch (Exception e) {
e.getMessage();
System.out.println("->EXCEPTION");
}

return null;

} // --end function makeDbConnection()-


/* ***********************************************************************************************/
/* -- closeConnection() FUNCTION ----------------------------------------------------------------*/
/* ***********************************************************************************************/

public void closeConnection()
{
try {
if( conn == null ) {
System.out.println( "->NO DB CONNECTION TO CLOSE" );
return;
}

conn.close();

if( conn.isClosed() == false ) {
System.out.println( "->DB COULD NOT BE CLOSED");
}
}
catch( SQLException e ) {
e.printStackTrace();
}

} // -end-method-closeConnection()

}


Hiç yorum yok: