cdmlib-io/src/main/java/eu/etaxonomy/cdm/io/berlinModel/out/BerlinModelExportBase.java

   1 /**
   2 * Copyright (C) 2007 EDIT
   3 * European Distributed Institute of Taxonomy
   4 * http://www.e-taxonomy.eu
   5 *
   6 * The contents of this file are subject to the Mozilla Public License Version 1.1
   7 * See LICENSE.TXT at the top of this package for the full license terms.
   8 */
   9
  10 package eu.etaxonomy.cdm.io.berlinModel.out;
  11
  12 import java.sql.ResultSet;
  13 import java.sql.SQLException;
  14 import java.util.Map;
  15
  16 import org.apache.log4j.Logger;
  17
  18 import eu.etaxonomy.cdm.io.common.CdmIoBase;
  19 import eu.etaxonomy.cdm.io.common.ICdmIO;
  20 import eu.etaxonomy.cdm.io.common.IExportConfigurator;
  21 import eu.etaxonomy.cdm.io.common.MapWrapper;
  22 import eu.etaxonomy.cdm.io.common.Source;
  23 import eu.etaxonomy.cdm.model.common.CdmBase;
  24
  25 /**
  26  * @author a.mueller
  27  * @created 20.03.2008
  28  * @version 1.0
  29  */
  30 public abstract class BerlinModelExportBase<T extends CdmBase> extends CdmIoBase<IExportConfigurator> implements ICdmIO<IExportConfigurator> {
  31         private static final Logger logger = Logger.getLogger(BerlinModelExportBase.class);
  32
  33         public BerlinModelExportBase() {
  34                 super();
  35         }
  36
  37         protected abstract boolean doInvoke(BerlinModelExportState<BerlinModelExportConfigurator> state);
  38
  39         /* (non-Javadoc)
  40          * @see eu.etaxonomy.cdm.io.common.CdmIoBase#doInvoke(eu.etaxonomy.cdm.io.common.IImportConfigurator, eu.etaxonomy.cdm.api.application.CdmApplicationController, java.util.Map)
  41          */
  42         @Override
  43         protected boolean doInvoke(IExportConfigurator config,
  44                         Map<String, MapWrapper<? extends CdmBase>> stores){
  45                 BerlinModelExportState<BerlinModelExportConfigurator> state = ((BerlinModelExportConfigurator)config).getState();
  46                 state.setConfig((BerlinModelExportConfigurator)config);
  47                 return doInvoke(state);
  48         }
  49
  50         protected boolean checkSqlServerColumnExists(Source source, String tableName, String columnName){
  51                 String strQuery = "SELECT  Count(t.id) as n " +
  52                                 " FROM sysobjects AS t " +
  53                                 " INNER JOIN syscolumns AS c ON t.id = c.id " +
  54                                 " WHERE (t.xtype = 'U') AND " +
  55                                 " (t.name = '" + tableName + "') AND " +
  56                                 " (c.name = '" + columnName + "')";
  57                 ResultSet rs = source.getResultSet(strQuery) ;
  58                 int n;
  59                 try {
  60                         rs.next();
  61                         n = rs.getInt("n");
  62                         return n>0;
  63                 } catch (SQLException e) {
  64                         e.printStackTrace();
  65                         return false;
  66                 }
  67
  68         }
  69
  70         public abstract Class<? extends CdmBase> getStandardMethodParameter();
  71
  72         protected void doCount(int count, int modCount, String pluralString){
  73                 if ((count % modCount ) == 0 && count!= 0 ){ logger.info(pluralString + " handled: " + (count));}
  74         }
  75
  76 }