strepsirrhini/office-gobmx
9
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

INTEGRATION: CWS qadev25 (1.1.2); FILE ADDED

Browse source 
2005/11/15 13:58:40 lla 1.1.2.3: #127811# write into log instead System.out.
2005/11/11 13:16:31 lla 1.1.2.2: #127811# database access
2005/11/11 11:00:22 lla 1.1.2.1: #127811# db access
This commit is contained in:
Oliver Bolte 2006-01-19 13:17:29 +00:00
parent ef65d15e66
commit cee1e644b9
1 changed files with 273 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

273
qadevOOo/runner/convwatch/DBHelper.java Normal file
View file

@ -0,0 +1,273 @@
/*************************************************************************
*
* OpenOffice.org - a multi-platform office productivity suite
*
* $RCSfile: DBHelper.java,v $
*
* $Revision: 1.2 $
*
* last change: $Author: obo $ $Date: 2006-01-19 14:17:29 $
*
* The Contents of this file are made available subject to
* the terms of GNU Lesser General Public License Version 2.1.
*
*
* GNU Lesser General Public License Version 2.1
* =============================================
* Copyright 2005 by Sun Microsystems, Inc.
* 901 San Antonio Road, Palo Alto, CA 94303, USA
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software Foundation.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
* MA 02111-1307 USA
*
************************************************************************/
package convwatch;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.GregorianCalendar;
import java.text.FieldPosition;
import java.util.Locale;
class ShareConnection
{
private static Connection m_aConnection = null;
public ShareConnection()
{}
public static Connection getConnection()
{
if (m_aConnection == null)
{
try
{
m_aConnection = DBHelper.getMySQLConnection();
}
catch(java.sql.SQLException e)
{
GlobalLogWriter.get().println("ERROR: can't connect to DB.");
m_aConnection = null;
}
}
return m_aConnection;
}
}
public class DBHelper
{
/**
* This method inserts given values into<br>
* the table 'states'
* @param values a set of comma separated values to be inserted
*/
public static void SQLinsertValues(Connection _aCon, String _sTableName, String value_names, String values)
{
if (_aCon == null)
{
GlobalLogWriter.get().println("ERROR: in SQLinsertValues, connection not established.");
return;
}
String aInsertStr = "";
aInsertStr = "INSERT INTO " + _sTableName + " (" + value_names + " ) VALUES (" + values + ")";
ExecSQL(_aCon, aInsertStr);
}
public static void SQLupdateValue(Connection _aCon, String _sTableName, String _sSet, String _sWhere)
{
if (_aCon == null)
{
GlobalLogWriter.get().println("ERROR: in SQLinsertValues, connection not established.");
return;
}
String aUpdateStr = "";
aUpdateStr = "UPDATE " + _sTableName + " SET " + _sSet + " WHERE " + _sWhere;
ExecSQL( _aCon, aUpdateStr );
}
/**
* This method establishes a Connection<br>
* with the database 'module_unit' on jakobus
*/
public static Connection getMySQLConnection() throws SQLException
{
try
{
Class.forName("org.gjt.mm.mysql.Driver");
Connection mysql = DriverManager.getConnection(
"jdbc:mysql://jakobus:3306/convwatch","admin","admin");
return mysql;
}
catch (ClassNotFoundException e)
{
GlobalLogWriter.get().println("Class not found exception caught: " + e.getMessage());
GlobalLogWriter.get().println("Maybe mysql.jar is not added to the classpath.");
}
return null;
}
/**
* This method removes all entries of the given<br>
* module/platform combination
* @param mdl the name of the module, e.g. sal
* @param os the name of the platform, e.g. unxsols
*/
// LLA: public static void SQLdeleteValues(Connection _aCon, String _sEnvironment, String _sUnitName, String _sMethodName, String _sCWS, String _sDate)
// LLA: {
// LLA: String sSQL =
// LLA: "DELETE FROM states WHERE " +
// LLA: " unit=" + DatabaseEntry.Quote(_sUnitName) +
// LLA: " AND pf=" + DatabaseEntry.Quote (_sEnvironment) +
// LLA: " AND meth=" + DatabaseEntry.Quote (_sMethodName) +
// LLA: " AND cws=" + DatabaseEntry.Quote(_sCWS) +
// LLA: " AND dt=" + DatabaseEntry.Quote(_sDate);
// LLA:
// LLA: // ExecSQL(_aCon, sSQL);
// LLA: }
public static void ExecSQL(Connection _aCon, String _sSQL)
{
Statement oStmt = null;
if (_aCon == null)
{
GlobalLogWriter.get().println("ERROR: in ExecSQL, connection not established.");
return;
}
// Connection oCon = null;
try
{
// oCon = getMySQLConnection();
oStmt = _aCon.createStatement();
GlobalLogWriter.get().println(_sSQL);
ResultSet oResult = oStmt.executeQuery(_sSQL);
}
catch(Exception e)
{
GlobalLogWriter.get().println("Couldn't execute sql string " + _sSQL);
}
}
// public static int QueryIntFromSQL(String _sSQL, String _sColumnName, String _sValue)
// {
// boolean bNeedSecondTry = false;
// int nValue = 0;
// do
// {
// try
// {
// nValue = QueryIntFromSQL(_sSQL, _sColumnName, _sValue);
// }
// catch (ValueNotFoundException e)
// {
// bNeedSecondTry = true;
// String sSQL = "INSERT INTO " + _sTable + "(" + _sColumnName + ") VALUES (" + _sValue + ")";
// ExecSQL(sSQL);
// }
// } while (bNeedSecondTry);
// return nValue;
// }
public static int QueryIntFromSQL(Connection _aCon, String _sSQL, String _sColumnName)
throws ValueNotFoundException
{
Statement oStmt = null;
Connection oCon = null;
int nValue = 0;
try
{
// oCon = getMySQLConnection();
oStmt = _aCon.createStatement();
ResultSet oResult = oStmt.executeQuery(_sSQL);
oResult.next();
try
{
if (_sColumnName.length() == 0)
{
// take the first row value (started with 1)
nValue = oResult.getInt(1);
}
else
{
nValue = oResult.getInt(_sColumnName);
}
// System.out.println("value: " + String.valueOf(nValue));
}
catch (SQLException e)
{
String sError = e.getMessage();
GlobalLogWriter.get().println("Original SQL error: " + sError);
throw new ValueNotFoundException("Cant execute SQL: " + _sSQL);
}
}
catch(SQLException e)
{
String sError = e.getMessage();
GlobalLogWriter.get().println("Couldn't execute sql string " + _sSQL + "\n" + sError);
}
return nValue;
}
public static String Quote(String _sToQuote)
{
String ts = "'";
String ds = "\"";
int nQuote = _sToQuote.indexOf(ts);
if (nQuote >= 0)
{
return ds + _sToQuote + ds;
}
return ts + _sToQuote + ts;
}
/* default date format in the MySQL DB yyyy-MM-dd */
public static String today()
{
return getDateString("yyyy-MM-dd");
}
private static String getDateString(String _sFormat)
{
GregorianCalendar aCalendar = new GregorianCalendar();
StringBuffer aBuf = new StringBuffer();
Locale aLocale = new Locale("en","US");
SimpleDateFormat aFormat = new SimpleDateFormat(_sFormat, aLocale);
aBuf = aFormat.format(aCalendar.getTime(), aBuf, new FieldPosition(0) );
// DebugHelper.writeInfo("Date: " + aBuf.toString());
return aBuf.toString();
}
public static final String sComma = ",";
public static final String sEqual = "=";
public static final String sAND = " AND ";
}