diff options
Diffstat (limited to 'qadevOOo/runner/convwatch/DBHelper.java')
| -rw-r--r-- | qadevOOo/runner/convwatch/DBHelper.java | 316 |
1 files changed, 316 insertions, 0 deletions
diff --git a/qadevOOo/runner/convwatch/DBHelper.java b/qadevOOo/runner/convwatch/DBHelper.java new file mode 100644 index 000000000000..e28fafb65ec4 --- /dev/null +++ b/qadevOOo/runner/convwatch/DBHelper.java @@ -0,0 +1,316 @@ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * This file is part of OpenOffice.org. + * + * OpenOffice.org is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License version 3 + * only, as published by the Free Software Foundation. + * + * OpenOffice.org 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 version 3 for more details + * (a copy is included in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU Lesser General Public License + * version 3 along with OpenOffice.org. If not, see + * <http://www.openoffice.org/license.html> + * for a copy of the LGPLv3 License. + * + ************************************************************************/ + +package convwatch; + +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.Statement; +import java.sql.ResultSet; +import java.sql.SQLException; + +import java.lang.Thread; +import java.util.StringTokenizer; + +class ShareConnection +{ + private Connection m_aConnection = null; + public ShareConnection() + {} + + public Connection getConnection() + { + if (m_aConnection == null) + { + try + { + m_aConnection = DBHelper.getMySQLConnection(); + } + catch(java.sql.SQLException e) + { + GlobalLogWriter.get().println("DB: ERROR: can't connect to DB."); + m_aConnection = null; + } + } + return m_aConnection; + } +} + + class MySQLThread extends Thread + { + Connection m_aCon = null; + String m_sSQL; + public MySQLThread(Connection _aCon, String _sSQL) + { + m_aCon = _aCon; + m_sSQL = _sSQL; + } + + public void run() + { + Statement oStmt = null; + if (m_aCon == null) + { + GlobalLogWriter.get().println("DB: ERROR: in ExecSQL, connection not established."); + return; + } + + // Connection oCon = null; + try + { + // oCon = getMySQLConnection(); + oStmt = m_aCon.createStatement(); + + GlobalLogWriter.get().println("DB: " + m_sSQL); + /* ResultSet oResult = */ + oStmt.executeUpdate(m_sSQL); + } + catch(Exception e) + { + GlobalLogWriter.get().println("DB: Couldn't execute sql string '" + m_sSQL + "'"); + GlobalLogWriter.get().println("DB: Reason: " + e.getMessage()); + } + } + } + +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 void SQLinsertValues(Connection _aCon, String _sTableName, String value_names, String values) + { + if (_aCon == null) + { + GlobalLogWriter.get().println("DB: ERROR: in SQLinsertValues, connection not established."); + return; + } + + // String aInsertStr = ""; + // + // aInsertStr = "INSERT INTO " + _sTableName + " (" + value_names + " ) VALUES (" + values + ")"; + // ExecSQL(_aCon, aInsertStr); + StringBuffer aInsertStr = new StringBuffer(); + + aInsertStr.append( "INSERT INTO " ) . append( _sTableName ); + aInsertStr.append( " (").append( value_names ).append ( ")" ); + aInsertStr.append(" VALUES (" ).append( values ).append( ")" ); + ExecSQL(_aCon, aInsertStr.toString() ); + } + + public void SQLupdateValue(Connection _aCon, String _sTableName, String _sSet, String _sWhere) + { + if (_aCon == null) + { + GlobalLogWriter.get().println("DB: ERROR: in SQLinsertValues, connection not established."); + return; + } + + // String aUpdateStr = ""; + // + // aUpdateStr = "UPDATE " + _sTableName + " SET " + _sSet + " WHERE " + _sWhere; + // ExecSQL( _aCon, aUpdateStr ); + StringBuffer aUpdateStr = new StringBuffer(); + + aUpdateStr.append( "UPDATE " ).append( _sTableName ) + .append( " SET " ).append( _sSet ) + .append( " WHERE " ).append( _sWhere ); + ExecSQL( _aCon, aUpdateStr.toString() ); + } + + private static String m_sDBServerName; + private static String m_sDBName; + private static String m_sDBUser; + private static String m_sDBPasswd; + + protected synchronized void fillDBConnection(String _sInfo) + { + StringTokenizer aTokenizer = new StringTokenizer(_sInfo,",",false); + while (aTokenizer.hasMoreTokens()) + { + String sPart = aTokenizer.nextToken(); + if (sPart.startsWith("db:")) + { + m_sDBName = sPart.substring(3); + // GlobalLogWriter.get().println("DB: source version: " + m_sSourceVersion); + } + else if (sPart.startsWith("user:")) + { + m_sDBUser = sPart.substring(5); + } + else if (sPart.startsWith("passwd:")) + { + m_sDBPasswd = sPart.substring(7); + } + else if (sPart.startsWith("server:")) + { + m_sDBServerName = sPart.substring(7); + } + } + } + + /** + * 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"); + String sConnection = "jdbc:mysql://" + m_sDBServerName + ":3306/" + m_sDBName; + // Connection mysql = DriverManager.getConnection( + // "jdbc:mysql://jakobus:3306/jobs_convwatch","admin","admin"); + Connection mysql = DriverManager.getConnection(sConnection, m_sDBUser, m_sDBPasswd); + return mysql; + } + catch (ClassNotFoundException e) + { + GlobalLogWriter.get().println("DB: Class not found exception caught: " + e.getMessage()); + GlobalLogWriter.get().println("DB: 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: } + + protected synchronized void ExecSQL(Connection _aCon, String _sSQL) + { + MySQLThread aSQLThread = new MySQLThread(_aCon, _sSQL); + aSQLThread.start(); + } + + + + // 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 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("DB: Original SQL error: " + sError); + throw new ValueNotFoundException("Cant execute SQL: " + _sSQL); + } + } + catch(SQLException e) + { + String sError = e.getMessage(); + GlobalLogWriter.get().println("DB: Couldn't execute sql string " + _sSQL + "\n" + sError); + } + return nValue; + } + + public 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 DateHelper.getDateString("yyyy-MM-dd"); + } + + public static final String sComma = ","; + public static final String sEqual = "="; + public static final String sAND = " AND "; + +} + |