qadevOOo/runner/convwatch/DBHelper.java

   1 /*
   2  * This file is part of the LibreOffice project.
   3  *
   4  * This Source Code Form is subject to the terms of the Mozilla Public
   5  * License, v. 2.0. If a copy of the MPL was not distributed with this
   6  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   7  *
   8  * This file incorporates work covered by the following license notice:
   9  *
  10  *   Licensed to the Apache Software Foundation (ASF) under one or more
  11  *   contributor license agreements. See the NOTICE file distributed
  12  *   with this work for additional information regarding copyright
  13  *   ownership. The ASF licenses this file to you under the Apache
  14  *   License, Version 2.0 (the "License"); you may not use this file
  15  *   except in compliance with the License. You may obtain a copy of
  16  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  17  */
  18
  19 package convwatch;
  20
  21 import java.sql.Connection;
  22 import java.sql.DriverManager;
  23 import java.sql.Statement;
  24 import java.sql.SQLException;
  25
  26 import java.util.StringTokenizer;
  27
  28 class ShareConnection
  29 {
  30     private Connection m_aConnection = null;
  31
  32     public Connection getConnection()
  33         {
  34             if (m_aConnection == null)
  35             {
  36                 try
  37                 {
  38                     m_aConnection = DBHelper.getMySQLConnection();
  39                 }
  40                 catch(java.sql.SQLException e)
  41                 {
  42                     GlobalLogWriter.get().println("DB: ERROR: can't connect to DB.");
  43                     m_aConnection = null;
  44                 }
  45             }
  46             return m_aConnection;
  47         }
  48 }
  49
  50     class MySQLThread extends Thread
  51     {
  52         private final Connection m_aCon;
  53         private final String m_sSQL;
  54         public MySQLThread(Connection _aCon, String _sSQL)
  55             {
  56                 m_aCon = _aCon;
  57                 m_sSQL = _sSQL;
  58             }
  59
  60         @Override
  61         public void run()
  62             {
  63                 Statement oStmt = null;
  64                 if (m_aCon == null)
  65                 {
  66                     GlobalLogWriter.get().println("DB: ERROR: in ExecSQL, connection not established.");
  67                     return;
  68                 }
  69
  70                 try
  71                 {
  72                     try
  73                     {
  74                         oStmt = m_aCon.createStatement();
  75
  76                         GlobalLogWriter.get().println("DB: " + m_sSQL);
  77                         /* ResultSet oResult = */
  78                         oStmt.executeUpdate(m_sSQL);
  79                     }
  80                     finally
  81                     {
  82                         if (oStmt != null)
  83                             oStmt.close();
  84                     }
  85                 }
  86                 catch(Exception e)
  87                 {
  88                     GlobalLogWriter.get().println("DB: Couldn't execute sql string '" + m_sSQL + "'");
  89                     GlobalLogWriter.get().println("DB: Reason: " + e.getMessage());
  90                 }
  91             }
  92     }
  93
  94 public class DBHelper
  95 {
  96     public void SQLupdateValue(Connection _aCon, String _sTableName, String _sSet, String _sWhere)
  97         {
  98             if (_aCon == null)
  99             {
 100                 GlobalLogWriter.get().println("DB: ERROR: in SQLinsertValues, connection not established.");
 101                 return;
 102             }
 103
 104             StringBuffer aUpdateStr = new StringBuffer();
 105
 106             aUpdateStr.append( "UPDATE " ).append( _sTableName )
 107                 .append( " SET " ).append( _sSet )
 108                 .append( " WHERE " ).append( _sWhere );
 109             ExecSQL( _aCon, aUpdateStr.toString() );
 110         }
 111
 112     private static String m_sDBServerName;
 113     private static String m_sDBName;
 114     private static String m_sDBUser;
 115     private static String m_sDBPasswd;
 116
 117     protected synchronized void fillDBConnection(String _sInfo)
 118         {
 119             StringTokenizer aTokenizer = new StringTokenizer(_sInfo,",",false);
 120             while (aTokenizer.hasMoreTokens())
 121             {
 122                 String sPart = aTokenizer.nextToken();
 123                 if (sPart.startsWith("db:"))
 124                 {
 125                     m_sDBName = sPart.substring(3);
 126                 }
 127                 else if (sPart.startsWith("user:"))
 128                 {
 129                     m_sDBUser = sPart.substring(5);
 130                 }
 131                 else if (sPart.startsWith("passwd:"))
 132                 {
 133                     m_sDBPasswd = sPart.substring(7);
 134                 }
 135                 else if (sPart.startsWith("server:"))
 136                 {
 137                     m_sDBServerName = sPart.substring(7);
 138                 }
 139             }
 140         }
 141
 142     /**
 143      * This method establishes a Connection<br>
 144      * with the database 'module_unit' on jakobus
 145      */
 146
 147     public static Connection getMySQLConnection() throws SQLException
 148         {
 149             try
 150             {
 151                 Class.forName("org.gjt.mm.mysql.Driver");
 152                 String sConnection = "jdbc:mysql://" + m_sDBServerName + ":3306/" + m_sDBName;
 153                 // Connection mysql = DriverManager.getConnection(
 154                 //    "jdbc:mysql://jakobus:3306/jobs_convwatch","admin","admin");
 155                 Connection mysql = DriverManager.getConnection(sConnection, m_sDBUser, m_sDBPasswd);
 156                 return mysql;
 157             }
 158             catch (ClassNotFoundException e)
 159             {
 160                 GlobalLogWriter.get().println("DB: Class not found exception caught: " + e.getMessage());
 161                 GlobalLogWriter.get().println("DB: Maybe mysql.jar is not added to the classpath.");
 162             }
 163             return null;
 164         }
 165
 166     private synchronized void ExecSQL(Connection _aCon, String _sSQL)
 167             {
 168                 MySQLThread aSQLThread = new MySQLThread(_aCon, _sSQL);
 169                 aSQLThread.start();
 170             }
 171
 172
 173
 174     public String Quote(String _sToQuote)
 175         {
 176             char ts = '\'';
 177             char ds = '"';
 178             int nQuote = _sToQuote.indexOf(ts);
 179             if (nQuote >= 0)
 180             {
 181                 return ds + _sToQuote + ds;
 182             }
 183             return ts + _sToQuote + ts;
 184         }
 185
 186     public static final String sEqual = "=";
 187     public static final String sAND = " AND ";
 188
 189 }
 190