qadevOOo/runner/convwatch/DB.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.util.StringTokenizer;
  23 import helper.OSHelper;
  24
  25 public class DB extends DBHelper
  26 {
  27     private static DB m_aDB = null;
  28
  29     // private ctor
  30     private DB()
  31         {
  32         }
  33
  34     private static synchronized DB getDB()
  35         {
  36             if (m_aDB == null)
  37             {
  38                 m_aDB = new DB();
  39             }
  40             return m_aDB;
  41         }
  42
  43     private String m_sSourceVersion;
  44     private String m_sDestinationVersion;
  45     private String m_sDocumentPool;
  46     private String m_sDocID;
  47     private String m_sDBDistinct;
  48
  49     public static void init(String _sDBInfoString)
  50         {
  51             if (_sDBInfoString == null) return;
  52             getDB().fillVariables(_sDBInfoString);
  53             getDB().updatestate_status("source started");
  54         }
  55
  56     private String getEnvironment()
  57         {
  58             if (OSHelper.isWindows())
  59             {
  60                 return "wntmsci";
  61             }
  62             else if ( OSHelper.isSolarisIntel())
  63             {
  64                 return "unxsoli";
  65             }
  66             else if ( OSHelper.isSolarisSparc())
  67             {
  68                 return "unxsols";
  69             }
  70             else if ( OSHelper.isLinuxIntel())
  71             {
  72                 return "unxlngi";
  73             }
  74             else
  75             {
  76                 GlobalLogWriter.get().println("DB: Unknown environment.");
  77                 GlobalLogWriter.get().println("DB: os.name := " + System.getProperty("os.name").toLowerCase());
  78                 GlobalLogWriter.get().println("DB: os.arch := " + System.getProperty("os.arch"));
  79                 return "";
  80             }
  81         }
  82
  83     // fill some db access important variables with values given out of a simple string
  84     // DOC_COMPARATOR_DB_INFO_STRING=p:m220,c:m224,d:demo_lla,src:m220,dest:m224,doc:demo_lla,id:294,distinct:81
  85
  86     private void fillVariables(String _sInfo)
  87         {
  88             fillDBConnection(_sInfo);
  89             getEnvironment();
  90
  91             StringTokenizer aTokenizer = new StringTokenizer(_sInfo,",",false);
  92             while (aTokenizer.hasMoreTokens())
  93             {
  94                 String sPart = aTokenizer.nextToken();
  95                 if (sPart.startsWith("p:"))
  96                 {
  97                     m_sSourceVersion = sPart.substring(2);
  98                     GlobalLogWriter.get().println("DB: source version: " + m_sSourceVersion);
  99                 }
 100                 else if (sPart.startsWith("src:"))
 101                 {
 102                     m_sSourceVersion = sPart.substring(4);
 103                     GlobalLogWriter.get().println("DB: source version: " + m_sSourceVersion);
 104                 }
 105                 else if (sPart.startsWith("c:"))
 106                 {
 107                     m_sDestinationVersion = sPart.substring(2);
 108                     GlobalLogWriter.get().println("DB: destination version: " + m_sDestinationVersion);
 109                 }
 110                 else if (sPart.startsWith("dest:"))
 111                 {
 112                     m_sDestinationVersion = sPart.substring(5);
 113                     GlobalLogWriter.get().println("DB: destination version: " + m_sDestinationVersion);
 114                 }
 115                 else if (sPart.startsWith("d:"))
 116                 {
 117                     m_sDocumentPool = sPart.substring(2);
 118                     GlobalLogWriter.get().println("DB: documentpool version: " + m_sDocumentPool);
 119                 }
 120                 else if (sPart.startsWith("doc:"))
 121                 {
 122                     m_sDocumentPool = sPart.substring(4);
 123                     GlobalLogWriter.get().println("DB: documentpool version: " + m_sDocumentPool);
 124                 }
 125                 else if (sPart.startsWith("id:"))
 126                 {
 127                     m_sDocID = sPart.substring(3);
 128                     GlobalLogWriter.get().println("DB: docid: " + m_sDocID);
 129                 }
 130                 else if (sPart.startsWith("distinct:"))
 131                 {
 132                     m_sDBDistinct = sPart.substring(9);
 133                     GlobalLogWriter.get().println("DB: distinct: " + m_sDBDistinct);
 134                 }
 135                 else
 136                 {
 137                 }
 138             }
 139         }
 140
 141     private void updatestate_status(String _sStatus)
 142         {
 143             Connection aCon = new ShareConnection().getConnection();
 144
 145             String sSet = "state=" + Quote(_sStatus);
 146             String sWhere = getWhereClause();
 147             if (sWhere.length() > 0)
 148             {
 149             SQLupdateValue( aCon, "status", sSet, sWhere );
 150         }
 151         }
 152
 153
 154     private String getWhereClause()
 155         {
 156             StringBuffer aWhereClause = new StringBuffer();
 157             boolean bAND = false;
 158             if (m_sDocID != null)
 159             {
 160                 aWhereClause.append( "docid" ). append(sEqual) . append(m_sDocID);
 161                 bAND = true;
 162             }
 163             if (bAND)
 164             {
 165                 aWhereClause.append(sAND);
 166             }
 167             if (m_sDBDistinct != null)
 168             {
 169                 aWhereClause.append( "dbdistinct2" ). append(sEqual) . append(Quote(m_sDBDistinct));
 170             }
 171             return aWhereClause.toString();
 172         }
 173
 174 }