[Openutils-svn] SF.net SVN: openutils:[1329] trunk/openutils-dbmigration/src/main/java/it/ openutils/migration/generic/JdbcIfTableExistsConditionalTask.java

[<fg...@us...>]

Revision: 1329
          http://openutils.svn.sourceforge.net/openutils/?rev=1329&view=rev
Author:   fgiust
Date:     2009-09-02 14:55:16 +0000 (Wed, 02 Sep 2009)

Log Message:
-----------
DBMIGRATION-1 new generic jdbc task

Added Paths:
-----------
    trunk/openutils-dbmigration/src/main/java/it/openutils/migration/generic/JdbcIfTableExistsConditionalTask.java

Added: trunk/openutils-dbmigration/src/main/java/it/openutils/migration/generic/JdbcIfTableExistsConditionalTask.java
===================================================================
--- trunk/openutils-dbmigration/src/main/java/it/openutils/migration/generic/JdbcIfTableExistsConditionalTask.java	                        (rev 0)
+++ trunk/openutils-dbmigration/src/main/java/it/openutils/migration/generic/JdbcIfTableExistsConditionalTask.java	2009-09-02 14:55:16 UTC (rev 1329)
@@ -0,0 +1,107 @@
+/*
+ * Copyright Openmind http://www.openmindonline.it
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package it.openutils.migration.generic;
+
+import it.openutils.migration.task.setup.BaseConditionalTask;
+
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import org.apache.commons.lang.StringUtils;
+import org.springframework.dao.DataAccessException;
+import org.springframework.jdbc.core.ConnectionCallback;
+import org.springframework.jdbc.core.simple.SimpleJdbcTemplate;
+
+
+/**
+ * Task that executes if a given table exists.
+ * @author fgiust
+ * @version $Id$
+ */
+public class JdbcIfTableExistsConditionalTask extends BaseConditionalTask
+{
+
+    /**
+     * Table name.
+     */
+    protected String table;
+
+    /**
+     * Catalog.
+     */
+    protected String catalog;
+
+    /**
+     * Schema.
+     */
+    protected String schema;
+
+    /**
+     * Sets the catalog.
+     * @param catalog the catalog to set
+     */
+    public void setCatalog(String catalog)
+    {
+        this.catalog = catalog;
+    }
+
+    /**
+     * Sets the schema.
+     * @param schema the schema to set
+     */
+    public void setSchema(String schema)
+    {
+        this.schema = schema;
+    }
+
+
+    /**
+     * Sets the table.
+     * @param table the table to set
+     */
+    public void setTable(String table)
+    {
+        this.table = table;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public boolean check(SimpleJdbcTemplate jdbcTemplate)
+    {
+
+        final String tableName = StringUtils.trim(table);
+
+        return (Boolean) jdbcTemplate.getJdbcOperations().execute(new ConnectionCallback()
+        {
+
+            public Object doInConnection(Connection con) throws SQLException, DataAccessException
+            {
+
+                DatabaseMetaData dbMetadata = con.getMetaData();
+                ResultSet rs = dbMetadata.getTables(catalog, schema, tableName, null);
+                boolean tableExists = rs.next();
+                rs.close();
+
+                return tableExists;
+            }
+        });
+    }
+
+}


Property changes on: trunk/openutils-dbmigration/src/main/java/it/openutils/migration/generic/JdbcIfTableExistsConditionalTask.java
___________________________________________________________________
Added: svn:mime-type
   + text/plain
Added: svn:keywords
   + Author Date Id Revision
Added: svn:eol-style
   + native


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.