Advertisement
| null |
|
[x]
Attachment Details
|
||
1: 2: 3: 4: 5: 6: 7: 8: 9: 10: 11: 12: 13: 14: 15: 16: 17: 18: 19: 20: 21: 22: 23: 24: 25: 26: 27: 28: 29: 30: 31: 32: 33: 34: 35: 36: 37: 38: 39: 40: 41: 42: 43: 44: 45: 46: 47: 48: 49: 50: 51: 52: 53: 54: 55: 56: 57: 58: 59: 60: 61: 62: 63: 64: 65: 66: 67: 68: 69: 70: 71: 72: 73: 74: 75: 76: 77: 78: 79: 80: 81: 82: 83: 84: 85: 86: 87: 88: 89: 90: 91: 92: 93: 94: 95: 96: 97: 98: 99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 124: 125: 126: 127: 128: 129: 130: 131: 132: 133: 134: 135: 136: 137: 138: 139: 140: 141: 142: 143: |
/*
* Database.java
*
* Created on November 1, 2006, 1:28 AM
*
* To change this template, choose Tools | Template Manager
* and open the template in the editor.
*/
//Database Connectivity - Requires ODBC
import java.util.Hashtable;
import javax.sql.*;
import java.sql.*;
import com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource;
public class glassfishDB {
Statement stmt;
ResultSet rs;
ResultSetMetaData meta;
Connection con;
long numberofrows = -1;
int errorState = 0;
String errorMessage = "";
String poolname = "";
glassfishDB(String poolName)
{
this.poolname = poolName;
}
void executeQuery(String query)
{
try
{
InitialContext ctx = new InitialContext();
com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource ds = (com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource) ctx.lookup("jdbc/" + poolname);
con = ds.getConnection();
stmt = con.createStatement();
// Do db operations.
// Do not close driver connection
rs = stmt.executeQuery(query);
rs.setFetchSize(1);
meta = rs.getMetaData();
}
catch (Exception e)
{
//System.out.println("Database Connection Error:" + e.toString());
errorMessage = e.toString();
errorState = 1;
}
}
void executeUpdate(String query)
{
try {
InitialContext ctx = new InitialContext();
com.sun.appserv.jdbc.DataSource ds = (com.sun.appserv.jdbc.DataSource) ctx.lookup("jdbc/" + poolname);
con = ds.getConnection();
stmt = con.createStatement();
stmt.executeUpdate(query);
}
catch (Exception e)
{
//System.out.println("Database Connection Error:" + e.toString());
errorMessage = e.toString();
errorState = 2;
}
}
long getRowCount()
{
try
{
int start = rs.getRow();
rs.last();
int last = rs.getRow();
rs.first();
numberofrows = last - start;
}
catch(Exception e)
{
//System.out.println("Database getRowCount() Error: " + e.toString());
errorMessage = e.toString();
errorState = 3;
}
return numberofrows;
}
synchronized Hashtable getNextRecord()
{
Hashtable ht = new Hashtable();
//Assign the next record to the hashtable
try
{
if (rs.next())
{
////System.out.println("Data Present");
//loop over the variable names and assign them and their values to the hashtable
for (int col = 1; col <= meta.getColumnCount(); col++) {
String varName = meta.getColumnName(col).trim();
////System.out.println("ColNAME " +varName);
String tdata = rs.getString(col);
if (tdata == null)
tdata = "";
ht.put(varName, tdata);
}
}
else
{
ht = null;
}
}
catch (Exception e)
{
//System.out.println("Database Read Error: " + e.toString());
errorMessage = e.toString();
errorState = 4;
}
return ht;
}
void close()
{
try
{
con.close();
}
catch (Exception e)
{
System.out.print("Database Close Error: " + e.toString() + "\n\n");
}
}
}
|
|
[x]
The Solution Rating System
|
||
|
With so many solutions, how can you tell which solutions are most likely to help you and which ones are not? To provide you with a tool to use, we rate our solutions based on various elements that most accurately determine if a solution is a quality solution. To explain what factors affect the solution rating, here are the elements we take into consideration when formulating our solution rating.
Your Input Matters If you have any suggestions that you would like to make for our rating system, please ask a question in the Suggestions Zone of Community Support. Thank you! |
||
|
Loading Advertisement... |