No commit message

future/symmetric-jdbc/.classpath

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src/main/java"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/jdk1.6.0_19"/>
+	<classpathentry combineaccessrules="false" kind="src" path="/symmetric-data"/>
+	<classpathentry kind="output" path="bin"/>
+</classpath>

future/symmetric-jdbc/.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>symmetric-jdbc</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+	</natures>
+</projectDescription>

future/symmetric-jdbc/src/main/java/org/jumpmind/symmetric/jdbc/db/AbstractJdbcPlatform.java

@@ -0,0 +1,31 @@
+package org.jumpmind.symmetric.jdbc.db;
+
+import javax.sql.DataSource;
+
+import org.jumpmind.symmetric.data.db.AbstractPlatform;
+import org.jumpmind.symmetric.data.model.Table;
+
+abstract public class AbstractJdbcPlatform extends AbstractPlatform {
+
+    protected DataSource dataSource;
+
+    protected JdbcModelReader jdbcModelReader;
+
+    @Override
+    public Table findTable(String catalog, String schema, String tableName) {
+        return null;
+    }
+
+    public java.util.List<Table> findTables(String catalog, String schema) {
+        return null;
+    };
+
+    protected void setDataSource(DataSource dataSource) {
+        this.dataSource = dataSource;
+    }
+
+    public DataSource getDataSource() {
+        return dataSource;
+    }
+
+}

future/symmetric-jdbc/src/main/java/org/jumpmind/symmetric/jdbc/db/DatabaseMetaDataWrapper.java

@@ -0,0 +1,194 @@
+package org.jumpmind.symmetric.jdbc.db;
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.
+ */
+
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+/**
+ * Wrapper class for database meta data that stores additional info.
+ * 
+ * @version $Revision: 329426 $
+ */
+public class DatabaseMetaDataWrapper
+{
+    /** The database meta data. */
+    private DatabaseMetaData _metaData;
+    /** The catalog to acess in the database. */
+    private String _catalog;
+    /** The schema(s) to acess in the database. */
+    private String _schemaPattern;
+    /** The table types to process. */
+    private String[] _tableTypes;
+
+    /**
+     * Returns the database meta data.
+     *
+     * @return The meta data
+     */
+    public DatabaseMetaData getMetaData()
+    {
+        return _metaData;
+    }
+
+    /**
+     * Sets the database meta data.
+     *
+     * @param metaData The meta data
+     */
+    public void setMetaData(DatabaseMetaData metaData)
+    {
+        _metaData = metaData;
+    }
+
+    /**
+     * Returns the catalog in the database to read.
+     *
+     * @return The catalog
+     */
+    public String getCatalog()
+    {
+        return _catalog;
+    }
+
+    /**
+     * Sets the catalog in the database to read.
+     * 
+     * @param catalog The catalog
+     */
+    public void setCatalog(String catalog)
+    {
+        _catalog = catalog;
+    }
+
+    /**
+     * Returns the schema in the database to read.
+     *
+     * @return The schema
+     */
+    public String getSchemaPattern()
+    {
+        return _schemaPattern;
+    }
+
+    /**
+     * Sets the schema in the database to read.
+     * 
+     * @param schema The schema
+     */
+    public void setSchemaPattern(String schema)
+    {
+        _schemaPattern = schema;
+    }
+
+    /**
+     * Returns the table types to recognize.
+     *
+     * @return The table types
+     */
+    public String[] getTableTypes()
+    {
+        return _tableTypes;
+    }
+
+    /**
+     * Sets the table types to recognize.
+     * 
+     * @param types The table types
+     */
+    public void setTableTypes(String[] types)
+    {
+        _tableTypes = types;
+    }
+
+    /**
+     * Convenience method to return the table meta data using the configured catalog,
+     * schema pattern and table types.
+     * 
+     * @param tableNamePattern The pattern identifying for which tables to return info
+     * @return The table meta data
+     * @throws SQLException If an error occurred retrieving the meta data
+     * @see DatabaseMetaData#getTables(java.lang.String, java.lang.String, java.lang.String, java.lang.String[])
+     */
+    public ResultSet getTables(String tableNamePattern) throws SQLException
+    {
+        return getMetaData().getTables(getCatalog(), getSchemaPattern(), tableNamePattern, getTableTypes());
+    }
+
+    /**
+     * Convenience method to return the column meta data using the configured catalog and
+     * schema pattern.
+     * 
+     * @param tableNamePattern  The pattern identifying for which tables to return info
+     * @param columnNamePattern The pattern identifying for which columns to return info
+     * @return The column meta data
+     * @throws SQLException If an error occurred retrieving the meta data
+     * @see DatabaseMetaData#getColumns(java.lang.String, java.lang.String, java.lang.String, java.lang.String)
+     */
+    public ResultSet getColumns(String tableNamePattern, String columnNamePattern) throws SQLException
+    {
+        return getMetaData().getColumns(getCatalog(), getSchemaPattern(), tableNamePattern, columnNamePattern);
+    }
+
+    /**
+     * Convenience method to return the primary key meta data using the configured catalog and
+     * schema pattern.
+     * 
+     * @param tableNamePattern The pattern identifying for which tables to return info
+     * @return The primary key meta data
+     * @throws SQLException If an error occurred retrieving the meta data
+     * @see DatabaseMetaData#getPrimaryKeys(java.lang.String, java.lang.String, java.lang.String)
+     */
+    public ResultSet getPrimaryKeys(String tableNamePattern) throws SQLException
+    {
+        return getMetaData().getPrimaryKeys(getCatalog(), getSchemaPattern(), tableNamePattern);
+    }
+
+    /**
+     * Convenience method to return the foreign key meta data using the configured catalog and
+     * schema pattern.
+     * 
+     * @param tableNamePattern The pattern identifying for which tables to return info
+     * @return The foreign key meta data
+     * @throws SQLException If an error occurred retrieving the meta data
+     * @see DatabaseMetaData#getImportedKeys(java.lang.String, java.lang.String, java.lang.String)
+     */
+    public ResultSet getForeignKeys(String tableNamePattern) throws SQLException
+    {
+        return getMetaData().getImportedKeys(getCatalog(), getSchemaPattern(), tableNamePattern);
+    }
+
+    /**
+     * Convenience method to return the index meta data using the configured catalog and
+     * schema pattern.
+     * 
+     * @param tableNamePattern The pattern identifying for which tables to return info
+     * @param unique           Whether to return only indices for unique values
+     * @param approximate      Whether the result is allowed to reflect approximate or out of data values
+     * @return The index meta data
+     * @throws SQLException If an error occurred retrieving the meta data
+     * @see DatabaseMetaData#getIndexInfo(java.lang.String, java.lang.String, java.lang.String, boolean, boolean)
+     */
+    public ResultSet getIndices(String tableNamePattern, boolean unique, boolean approximate) throws SQLException
+    {
+        return getMetaData().getIndexInfo(getCatalog(), getSchemaPattern(), tableNamePattern, unique, approximate);
+    }
+}