From c6103c7c9a6b6971d2aa0b8e3997608cb5f2c36f Mon Sep 17 00:00:00 2001
From: lresende <lresende@13f79535-47bb-0310-9956-ffa450edef68>
Date: Mon, 2 Nov 2009 22:22:29 +0000
Subject: Move the das folder as new trunk for das sub project

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@832144 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/tuscany/das/rdb/util/Column.java    |  57 ++++++
 .../org/apache/tuscany/das/rdb/util/DBSchema.java  |  45 +++++
 .../tuscany/das/rdb/util/DBToSchemaFile.java       | 119 ++++++++++++
 .../tuscany/das/rdb/util/DBToXSDGenerator.java     |  88 +++++++++
 .../apache/tuscany/das/rdb/util/ForeignKey.java    |  51 ++++++
 .../apache/tuscany/das/rdb/util/ForeignKeyRef.java |  44 +++++
 .../tuscany/das/rdb/util/ModelXSDGenOption.java    | 133 ++++++++++++++
 .../tuscany/das/rdb/util/SQLTypeChecker.java       | 186 +++++++++++++++++++
 .../tuscany/das/rdb/util/SchemaFileToXSD.java      | 200 +++++++++++++++++++++
 .../org/apache/tuscany/das/rdb/util/Table.java     |  66 +++++++
 10 files changed, 989 insertions(+)
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Column.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBSchema.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToSchemaFile.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToXSDGenerator.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKey.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKeyRef.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ModelXSDGenOption.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SQLTypeChecker.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SchemaFileToXSD.java
 create mode 100644 das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Table.java

(limited to 'das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb')

diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Column.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Column.java
new file mode 100644
index 0000000000..cbadde0717
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Column.java
@@ -0,0 +1,57 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+public class Column {
+	private String name;
+	private String type;
+	private boolean isPK;
+	private boolean isRequired;
+	
+	protected String getName() {
+		return name;
+	}
+	protected void setName(String name) {
+		this.name = name;
+	}
+	protected String getType() {
+		return type;
+	}
+	protected void setType(String type) {
+		this.type = type;
+	}
+	protected boolean isPK() {
+		return isPK;
+	}
+	protected void setPK(boolean isPK) {
+		this.isPK = isPK;
+	}
+	protected boolean isRequired() {
+		return isRequired;
+	}
+	protected void setRequired(boolean isRequired) {
+		this.isRequired = isRequired;
+	}
+	
+	public String toString() {
+		StringBuffer dbSchemaStr = new StringBuffer();
+		dbSchemaStr.append("Name:"+this.getName()+", Type:"+this.getType()+", isPK:"+this.isPK()+", isRequired:"+this.isRequired()+"\n");
+		return dbSchemaStr.toString();
+	}	
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBSchema.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBSchema.java
new file mode 100644
index 0000000000..4ae038b24d
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBSchema.java
@@ -0,0 +1,45 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class DBSchema {
+	private List tables = new ArrayList();
+
+	protected List getTables() {
+		return tables;
+	}
+
+	protected void setTables(List tables) {
+		this.tables = tables;
+	}
+	
+	public String toString() {
+		StringBuffer dbSchemaStr = new StringBuffer();
+		dbSchemaStr.append("_____DB SChema_______\n");
+		for(int i=0; i<this.tables.size(); i++) {			
+			Table curTable = (Table)this.tables.get(i);
+			dbSchemaStr.append(curTable);
+		}
+		
+		return dbSchemaStr.toString();
+	}
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToSchemaFile.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToSchemaFile.java
new file mode 100644
index 0000000000..1dfa7919fd
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToSchemaFile.java
@@ -0,0 +1,119 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+import java.io.File;
+import java.io.InputStreamReader;
+
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamReader;
+
+import org.apache.log4j.Logger;
+import org.apache.tools.ant.Project;
+import org.apache.torque.task.TorqueJDBCTransformTask;
+
+public class DBToSchemaFile {
+	private static final Logger logger = Logger.getLogger(DBToSchemaFile.class);
+	private static ModelXSDGenOption mo = null;//schemaFileName should not be null. id modelFileName null STDOUT
+	
+	protected static void schemaFileFromDB() throws Exception {
+		Project p = new Project();
+	    p.setBaseDir(new File("."));
+		TorqueJDBCTransformTask tsk = new TorqueJDBCTransformTask();
+		tsk.setProject(p);
+		tsk.setDbDriver(mo.getDriverClass());
+		tsk.setDbUrl(mo.getDatabaseURL());
+		tsk.setSameJavaName(true);
+		tsk.setDbSchema(mo.getSchemaName());
+		tsk.setTaskName("jdbc");
+		tsk.setDbUser(mo.getUserName());
+		tsk.setDbPassword(mo.getPassword());
+		if(!mo.getSchemaFile().trim().equals("")) {
+			File schemaFile = new File( mo.getSchemaFile());
+			schemaFile.createNewFile();
+		}
+		tsk.setOutputFile(mo.getSchemaFile());
+		tsk.execute();
+	}
+	
+	protected static void read(String dbInfoFileName) throws Exception {
+		XMLInputFactory xmlFactory = XMLInputFactory.newInstance();
+		
+		XMLStreamReader reader = xmlFactory.createXMLStreamReader(new InputStreamReader(DBToXSDGenerator.getStream(dbInfoFileName)));
+		mo = new ModelXSDGenOption();
+        while (true) {
+            int event = reader.next();
+            if(javax.xml.stream.XMLStreamConstants.END_DOCUMENT == event) {
+            	break;
+            }
+            
+            switch (event) {            
+	            case javax.xml.stream.XMLStreamConstants.START_ELEMENT: {
+	               if (reader.getName().getLocalPart().equals("ConnectionProperties")) {
+	            	   mo.setDriverClass(reader.getAttributeValue(null, "driverClass"));
+	                   mo.setDatabaseURL(reader.getAttributeValue(null, "databaseURL"));
+	                   mo.setSchemaName(reader.getAttributeValue(null, "schemaName"));
+	                   mo.setUserName(reader.getAttributeValue(null, "userName"));
+	                	if(mo.getUserName() == null)
+	                		mo.setUserName("");
+	                	mo.setPassword(reader.getAttributeValue(null, "password"));
+	                	if(mo.getPassword() == null)
+	                		mo.setPassword("");
+	                } else if (reader.getName().getLocalPart().equals("ConnectionInfo")) {	                
+	                	//ignore
+	                } else if (reader.getName().getLocalPart().equals("Config")) {
+	                	//ignore
+	                } else if (reader.getName().getLocalPart().equals("OutFiles")) {	                
+	                	mo.setSchemaFile(reader.getAttributeValue(null, "schemaFile"));
+	                	mo.setModelFile(reader.getAttributeValue(null, "modelFile"));
+	                } else {
+	                	throw new RuntimeException("not got dbInfo  - tableNames List or connectionInfo:"+reader.getName()+":");
+	                }
+	                break;
+	            }
+            }            
+        }
+        
+        if (logger.isDebugEnabled()) {
+			logger.debug("driverClass:"+mo.getDriverClass());
+			logger.debug("url:"+mo.getDatabaseURL());
+			logger.debug("schemaName:"+mo.getSchemaName());
+			logger.debug("schemaFileName:"+mo.getSchemaFile());
+			logger.debug("modelFileName:"+mo.getModelFile());
+			logger.debug("userName:"+mo.getUserName());
+			logger.debug("password:"+mo.getPassword());
+		}            
+
+        if(mo.getDriverClass() == null || mo.getDatabaseURL() == null || mo.getSchemaName() == null || mo.getSchemaFile() == null 
+        		|| mo.getModelFile() == null) {
+     	   throw new RuntimeException("Required inputs missing - check driverClass, url, schemaName, schemaFile, modelFile!");
+        }
+
+        return;
+    }
+
+	public static ModelXSDGenOption getMo() {
+		return mo;
+	}
+
+	public static void setMo(ModelXSDGenOption mo) {
+		DBToSchemaFile.mo = mo;
+	}
+	
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToXSDGenerator.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToXSDGenerator.java
new file mode 100644
index 0000000000..a5e510dedf
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/DBToXSDGenerator.java
@@ -0,0 +1,88 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+import java.io.InputStream;
+
+public class DBToXSDGenerator {
+	/**
+	 * Output is dbSchemaFile as specified in dbInfoFileName.schemaFile
+	 * @param dbInfoFileName  name of file which contains db connection info and output files names for dbschema and model 
+	 * @throws Exception
+	 */	
+	public static void getSchemaFileFromDB(String dbInfoFileName) throws Exception {
+		DBToSchemaFile.read(dbInfoFileName);
+		DBToSchemaFile.schemaFileFromDB();
+	}
+	
+	/**
+	 * If user supplies schemaFileName and modelFileName will use it instead of the one from DBToSchemaFile.
+	 * schemaFile should exist. If modelFileName is null, will use STDOUT.
+	 * @param schemaFileName the result of Torque output
+	 * @throws Exception
+	 */
+	public static void getModelFileFromSchemaFile(String schemaFileName, String modelFileName) throws Exception {
+		if(schemaFileName == null || schemaFileName.trim().equals("")) {
+			throw new RuntimeException("Null or empty schemaFileName");
+		}
+		
+		SchemaFileToXSD.convert(schemaFileName, modelFileName);
+	}
+	
+	/**
+	 * If user supplies schemaFileName and modelFileName through ModelXSDGenOption, will use it instead of 
+	 * the one from DBToSchemaFile. schemaFile should exist. If modelFileName is null, will use STDOUT.
+	 * @param ModelXSDGenOption 
+	 * @throws Exception
+	 */
+	public static void getModelFileFromSchemaFile(ModelXSDGenOption mo) throws Exception {
+		getModelFileFromSchemaFile(mo.getSchemaFile(), mo.getModelFile());
+	}
+	
+	/**
+	 * All in one
+	 * @param dbInfoFileName e.g. DBConnectionConfig.xml
+	 * @throws Exception
+	 */
+	public static void getModelFileFromDB(String dbInfoFileName) throws Exception {
+		DBToSchemaFile.read(dbInfoFileName);
+		DBToSchemaFile.schemaFileFromDB();
+		getModelFileFromSchemaFile(DBToSchemaFile.getMo());
+	}
+	
+	/**
+	 * Useful for plugin
+	 */
+	public static void getModelFileFromDB(ModelXSDGenOption mo) throws Exception {
+		if(mo.getSchemaFile() == null || mo.getSchemaFile().trim().equals("") || 
+			mo.getDriverClass() == null || mo.getDriverClass().trim().equals("") || 
+			mo.getDatabaseURL() == null || mo.getDatabaseURL().trim().equals("") ||
+			mo.getSchemaName() == null || mo.getSchemaName().trim().equals("")) {
+			throw new RuntimeException("Required inputs missing - check driverClass, url, schemaName, schemaFile!");
+		}
+		
+		DBToSchemaFile.setMo(mo);	
+		DBToSchemaFile.schemaFileFromDB();
+		getModelFileFromSchemaFile(DBToSchemaFile.getMo().getSchemaFile(), DBToSchemaFile.getMo().getModelFile());
+	}
+	
+    protected static InputStream getStream(String fileName) {
+        return Thread.currentThread().getContextClassLoader().getResourceAsStream(fileName);
+    }    
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKey.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKey.java
new file mode 100644
index 0000000000..d602a30194
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKey.java
@@ -0,0 +1,51 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class ForeignKey {
+	private String foreignTableName;
+	private List fkRefs = new ArrayList();
+	
+	protected String getForeignTableName() {
+		return foreignTableName;
+	}
+	protected void setForeignTableName(String foreignTableName) {
+		this.foreignTableName = foreignTableName;
+	}
+	protected List getFkRefs() {
+		return fkRefs;
+	}
+	protected void setFkRefs(List fkRefs) {
+		this.fkRefs = fkRefs;
+	}
+	
+	public String toString() {
+		StringBuffer dbSchemaStr = new StringBuffer();
+		dbSchemaStr.append("_____Foreign Key_______"+this.foreignTableName+"\n");
+		for(int i=0; i<fkRefs.size(); i++) {
+			ForeignKeyRef curFkRef = (ForeignKeyRef)fkRefs.get(i); 
+			dbSchemaStr.append(curFkRef);
+		}
+
+		return dbSchemaStr.toString();
+	}	
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKeyRef.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKeyRef.java
new file mode 100644
index 0000000000..4be4f7435a
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ForeignKeyRef.java
@@ -0,0 +1,44 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+public class ForeignKeyRef {
+	private String foreign;
+	private String local;
+	
+	protected String getForeign() {
+		return foreign;
+	}
+	protected void setForeign(String foreign) {
+		this.foreign = foreign;
+	}
+	protected String getLocal() {
+		return local;
+	}
+	protected void setLocal(String local) {
+		this.local = local;
+	}
+	
+	public String toString() {
+		StringBuffer dbSchemaStr = new StringBuffer();
+		dbSchemaStr.append("Foreign:"+this.foreign+", Local:"+this.local+"\n");
+
+		return dbSchemaStr.toString();
+	}	
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ModelXSDGenOption.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ModelXSDGenOption.java
new file mode 100644
index 0000000000..e9ac04cb5e
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/ModelXSDGenOption.java
@@ -0,0 +1,133 @@
+/**
+ *
+ *  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.
+ */
+package org.apache.tuscany.das.rdb.util;
+
+
+public class ModelXSDGenOption {
+
+    /**
+     * Name of the schema file
+     *
+     * @parameter
+     */
+    private String schemaFile;
+
+    /**
+     * Name of the model file
+     *
+     * @parameter
+     */
+    private String modelFile;
+
+    /**
+     * Name of the DBDriver class Name
+     *
+     * @parameter
+     */
+    private String driverClass;
+
+    /**
+     * Name of the DB URL
+     *
+     * @parameter
+     */
+    private String databaseURL;
+    
+    /**
+     * Name of the DB Schema Name
+     *
+     * @parameter
+     */    
+    private String schemaName;
+
+    /**
+     * Optional user name.
+     *
+     * @parameter
+     */
+    private String userName;
+
+    /**
+     * Optional password.
+     *
+     * @parameter
+     */
+    private String password;
+
+    public ModelXSDGenOption() {
+    }
+
+	public String getSchemaFile() {
+		return schemaFile;
+	}
+
+	public void setSchemaFile(String schemaFile) {
+		this.schemaFile = schemaFile;
+	}
+
+	public String getModelFile() {
+		return modelFile;
+	}
+
+	public void setModelFile(String modelFile) {
+		this.modelFile = modelFile;
+	}
+
+	public String getDriverClass() {
+		return driverClass;
+	}
+
+	public void setDriverClass(String driverClass) {
+		this.driverClass = driverClass;
+	}
+
+	public String getDatabaseURL() {
+		return databaseURL;
+	}
+
+	public void setDatabaseURL(String databaseURL) {
+		this.databaseURL = databaseURL;
+	}
+
+	public String getSchemaName() {
+		return schemaName;
+	}
+
+	public void setSchemaName(String schemaName) {
+		this.schemaName = schemaName;
+	}
+
+	public String getUserName() {
+		return userName;
+	}
+
+	public void setUserName(String userName) {
+		this.userName = userName;
+	}
+
+	public String getPassword() {
+		return password;
+	}
+
+	public void setPassword(String password) {
+		this.password = password;
+	}
+	
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SQLTypeChecker.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SQLTypeChecker.java
new file mode 100644
index 0000000000..73fe977719
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SQLTypeChecker.java
@@ -0,0 +1,186 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+import java.sql.Types;
+
+public class SQLTypeChecker {
+	
+	public static int getSQLTypeFromString(String sqlTypeString) {
+		if(sqlTypeString.equals("CHAR")) return Types.CHAR;
+		if(sqlTypeString.equals("VARCHAR")) return Types.VARCHAR;
+		if(sqlTypeString.equals("LONGVARCHAR")) return Types.LONGVARCHAR;
+		if(sqlTypeString.equals("NUMERIC")) return Types.NUMERIC;
+		if(sqlTypeString.equals("DECIMAL")) return Types.DECIMAL;
+		if(sqlTypeString.equals("BIT")) return Types.BIT;
+		if(sqlTypeString.equals("BOOLEAN")) return Types.BOOLEAN;
+		if(sqlTypeString.equals("TINYINT")) return Types.TINYINT;
+		if(sqlTypeString.equals("SMALLINT")) return Types.SMALLINT;
+		if(sqlTypeString.equals("INTEGER")) return Types.INTEGER;
+		if(sqlTypeString.equals("BIGINT")) return Types.BIGINT;
+		if(sqlTypeString.equals("REAL")) return Types.REAL;
+		if(sqlTypeString.equals("FLOAT")) return Types.FLOAT;
+		if(sqlTypeString.equals("DOUBLE")) return Types.DOUBLE;
+		if(sqlTypeString.equals("BINARY")) return Types.BINARY;
+		if(sqlTypeString.equals("VARBINARY")) return Types.VARBINARY;
+		if(sqlTypeString.equals("LONGVARBINARY")) return Types.LONGVARBINARY;
+		if(sqlTypeString.equals("DATE")) return Types.DATE;
+		if(sqlTypeString.equals("TIME")) return Types.TIME;
+		if(sqlTypeString.equals("TIMESTAMP")) return Types.TIMESTAMP;
+		if(sqlTypeString.equals("CLOB")) return Types.CLOB;
+		if(sqlTypeString.equals("BLOB")) return Types.BLOB;
+		if(sqlTypeString.equals("ARRAY")) return Types.ARRAY;
+		if(sqlTypeString.equals("DISTINCT")) return Types.DISTINCT;
+		if(sqlTypeString.equals("STRUCT")) return Types.STRUCT;
+		if(sqlTypeString.equals("REF")) return Types.REF;
+		if(sqlTypeString.equals("DATALINK")) return Types.DATALINK;
+		if(sqlTypeString.equals("JAVA_OBJECT")) return Types.JAVA_OBJECT;
+		return Types.OTHER;
+	}
+
+	/*xsd : SDO 
+	anySimpleType Object
+	anyType DataObject
+	anyURI URI
+	base64Binary Bytes
+	boolean Boolean
+	byte Byte
+	date YearMonthDay
+	dateTime DateTime
+	decimal Decimal
+	double Double
+	duration Duration
+	ENTITIES Strings
+	ENTITY String
+	float Float
+	gDay Day
+	gMonth Month
+	gMonthDay MonthDay
+	gYear Year
+	gYearMonth YearMonth
+	hexBinary Bytes
+	ID String
+	IDREF String
+	IDREFS Strings
+	int Int
+	integer Integer
+	language String
+	long Long
+	Name String
+	NCName String
+	negativeInteger Integer
+	NMTOKEN String
+	NMTOKENS Strings
+	nonNegativeInteger Integer
+	nonPositiveInteger Integer
+	normalizedString String
+	NOTATION String
+	positiveInteger Integer
+	QName URI
+	short Short
+	string String
+	time Time
+	token String
+	unsignedByte Short
+	unsignedInt long
+	unsignedLong Integer
+	unsignedShort Int*/
+	static final String anySimpleTypeXSD = "anySimpleType";
+	static final String anyTypeXSD = "anyType";
+	static final String anyURIXSD = "anyURI";
+	static final String base64BinaryXSD = "base64Binary";
+	static final String booleanXSD = "boolean";
+	static final String byteXSD = "byte";
+	static final String dateXSD = "date";
+	static final String dateTimeXSD = "dateTime";
+	static final String decimalXSD = "decimal";
+	static final String doubleXSD = "double";
+	static final String durationXSD = "duration";
+	static final String ENTITIESXSD = "ENTITIES";
+	static final String ENTITYXSD = "ENTITY";
+	static final String floatXSD = "float"; 
+	static final String gDayXSD = "gDay"; 
+	static final String gMonthXSD = "gMonth"; 
+	static final String gMonthDayXSD = "gMonthDay"; 
+	static final String gYearXSD = "gYear"; 
+	static final String gYearMonthXSD = "gYearMonth"; 
+	static final String hexBinaryXSD = "hexBinary"; 
+	static final String IDXSD = "ID"; 
+	static final String IDREFXSD = "IDREF"; 
+	static final String IDREFSXSD = "IDREF"; 
+	static final String intXSD = "int"; 
+	static final String integerXSD = "integer"; 
+	static final String languageXSD = "language"; 
+	static final String longXSD = "long"; 
+	static final String NameXSD = "Name"; 
+	static final String NCNameXSD = "NCName"; 
+	static final String negativeIntegerXSD = "negativeInteger"; 
+	static final String NMTOKENXSD = "NMTOKEN"; 
+	static final String NMTOKENSXSD = "NMTOKENS";
+	static final String nonNegativeIntegerXSD = "nonNegativeInteger"; 
+	static final String nonPositiveIntegerXSD = "nonPositiveInteger"; 
+	static final String normalizedStringXSD = "normalizedString"; 
+	static final String NOTATIONXSD = "NOTATION"; 
+	static final String positiveIntegerXSD = "positiveInteger"; 
+	static final String QNameXSD = "QName"; 
+	static final String shortXSD = "short"; 
+	static final String stringXSD = "string"; 
+	static final String timeXSD = "time"; 
+	static final String tokenXSD = "token"; 
+	static final String unsignedByteXSD = "unsignedByte"; 
+	static final String unsignedIntXSD = "unsignedInt"; 
+	static final String unsignedLongXSD = "unsignedLong"; 
+	static final String unsignedShortXSD = "unsignedShort"; 
+	
+	public static String xsdTypeForSDOType(String sdoTypeName) {
+		if(sdoTypeName.equals("Object")) return anySimpleTypeXSD;
+		if(sdoTypeName.equals("DataObject")) return anyTypeXSD;
+		if(sdoTypeName.equals("URI")) return anyURIXSD;
+		if(sdoTypeName.equals("Bytes")) return base64BinaryXSD;
+		if(sdoTypeName.equals("Boolean")) return booleanXSD;
+		if(sdoTypeName.equals("boolean")) return booleanXSD;
+		if(sdoTypeName.equals("Byte")) return byteXSD;
+		if(sdoTypeName.equals("YearMonthDay")) return dateXSD;
+		if(sdoTypeName.equals("DateTime")) return dateTimeXSD;
+		if(sdoTypeName.equals("Date")) return dateTimeXSD;
+		if(sdoTypeName.equals("Decimal")) return decimalXSD;
+		if(sdoTypeName.equals("Double")) return doubleXSD;
+		if(sdoTypeName.equals("double")) return doubleXSD;
+		if(sdoTypeName.equals("Duration")) return durationXSD;
+		if(sdoTypeName.equals("Strings")) return ENTITIESXSD;
+		if(sdoTypeName.equals("String")) return stringXSD;
+		if(sdoTypeName.equals("Float")) return floatXSD;
+		if(sdoTypeName.equals("float")) return floatXSD;
+		if(sdoTypeName.equals("Day")) return gDayXSD;
+		if(sdoTypeName.equals("Month")) return gMonthXSD;
+		if(sdoTypeName.equals("MonthDay")) return gMonthDayXSD;
+		if(sdoTypeName.equals("Year")) return gYearXSD;
+		if(sdoTypeName.equals("YearMonth")) return gYearMonthXSD;
+		if(sdoTypeName.equals("Bytes")) return hexBinaryXSD;
+		if(sdoTypeName.equals("Int")) return intXSD;
+		if(sdoTypeName.equals("IntObject")) return intXSD;
+		if(sdoTypeName.equals("Integer")) return integerXSD;
+		if(sdoTypeName.equals("Long")) return longXSD;		
+		if(sdoTypeName.equals("long")) return longXSD;
+		if(sdoTypeName.equals("Short")) return shortXSD;
+		if(sdoTypeName.equals("Time")) return timeXSD;
+		if(sdoTypeName.equals("long")) return unsignedIntXSD;
+		return "";
+	}
+}
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SchemaFileToXSD.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SchemaFileToXSD.java
new file mode 100644
index 0000000000..54cd0aa02b
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/SchemaFileToXSD.java
@@ -0,0 +1,200 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.InputStreamReader;
+import java.io.PrintStream;
+import java.util.ArrayList;
+import java.util.Hashtable;
+
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamReader;
+
+import org.apache.log4j.Logger;
+import org.apache.tuscany.das.rdb.graphbuilder.schema.ResultSetTypeMap;
+
+import commonj.sdo.Type;
+
+public class SchemaFileToXSD {
+	private static final Logger logger = Logger.getLogger(SchemaFileToXSD.class);
+	private static XMLInputFactory xmlFactory;
+	
+	protected static DBSchema read(XMLStreamReader reader) throws Exception {
+		DBSchema dbSchema = new DBSchema();
+		Table table = null;
+		Column column = null;
+		ForeignKey fk = null;
+		ForeignKeyRef fkRef = null;
+		
+        while (true) {
+            int event = reader.next();
+            if(javax.xml.stream.XMLStreamConstants.END_DOCUMENT == event) {
+            	break;
+            }
+            
+            switch (event) {
+	            case javax.xml.stream.XMLStreamConstants.START_ELEMENT:
+	                if (reader.getName().getLocalPart().equals("table")) {
+	                	table = new Table();
+	                	table.setName(reader.getAttributeValue(null, "name"));
+	                } else if (reader.getName().getLocalPart().equals("column")) {
+	                	column = new Column();
+	                	column.setName(reader.getAttributeValue(null, "name"));
+	                	column.setPK(Boolean.getBoolean(reader.getAttributeValue(null, "primaryKey")));
+	                	column.setRequired(Boolean.getBoolean(reader.getAttributeValue(null, "required")));
+	                	column.setType(reader.getAttributeValue(null, "type"));
+	                } 
+	                else if (reader.getName().getLocalPart().equals("foreign-key")) {
+	                	fk = new ForeignKey();
+	                	fk.setForeignTableName(reader.getAttributeValue(null,"foreignTable"));
+	                }
+	                else if (reader.getName().getLocalPart().equals("reference")) {
+	                	fkRef = new ForeignKeyRef();
+	                	fkRef.setForeign(reader.getAttributeValue(null,"foreign"));
+	                	fkRef.setLocal(reader.getAttributeValue(null,"local"));
+	                }
+	                else if (reader.getName().getLocalPart().equals("database")) {
+	                	//ignore
+	                } else {
+	                	throw new RuntimeException("not valid element:"+reader.getName()+":");
+	                }
+	                break;
+	                
+	            case javax.xml.stream.XMLStreamConstants.END_ELEMENT:
+	            	if (reader.getName().getLocalPart().equals("table")) {
+	            		dbSchema.getTables().add(table);
+	            	}
+	            	
+	            	if (reader.getName().getLocalPart().equals("column")) {
+	            		if(table != null) {
+	            			table.getColumns().add(column);
+	            		}
+	            	}
+	            	
+	            	if (reader.getName().getLocalPart().equals("reference")) {
+	            		if(fk != null) {
+	            			fk.getFkRefs().add(fkRef);
+	            		}
+	            	}
+	            	
+	            	if (reader.getName().getLocalPart().equals("foreign-key")) {
+	            		if(table != null) {
+	            			table.getFks().add(fk);
+	            		}
+	            	}
+	            	
+	            	break;
+            }
+        }
+        
+        if (logger.isDebugEnabled()) {
+        	logger.debug(dbSchema);
+        }
+        
+        return dbSchema;
+    }
+
+	protected static void convert(String schemaFileName, String xsdModelFileName) throws Exception{
+		xmlFactory = XMLInputFactory.newInstance();
+		
+		File schemaFile = new File(schemaFileName);
+		FileInputStream flStrm = new FileInputStream(schemaFile);
+		
+		XMLStreamReader reader = xmlFactory.createXMLStreamReader(new InputStreamReader(flStrm));
+		
+		DBSchema dbSchema = read(reader);
+		flStrm.close();
+		generateXSD(dbSchema, xsdModelFileName);
+	}
+	
+	protected static void generateXSD(DBSchema dbSchema, String xsdModelFileName) throws Exception {
+		boolean writeFilesToDir = false;
+		String startLine = "<xsd:schema xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:this=\"http:///org.apache.tuscany.das.rdb.test/schemaModel.xsd\" targetNamespace=\"http:///org.apache.tuscany.das.rdb.test/schemaModel.xsd\">\n";
+		String endLine = "</xsd:schema>"; 
+			
+		if(xsdModelFileName != null && !xsdModelFileName.trim().equals("")) {
+			writeFilesToDir = true;
+		}
+		
+		//get all FKs to form a Map - PKtable -> FKTable , e.g. if CITIES has FK such that CITIES.STATE_ID is STATES.ID, then
+		//the map shall have STATES -> CITIES, TABLE2,...
+		Hashtable pkTofkTable = new Hashtable();
+		
+		for(int i=0; i<dbSchema.getTables().size(); i++) {
+			Table curTable = (Table)dbSchema.getTables().get(i);
+			for(int k=0; k<curTable.getFks().size(); k++) {
+				ForeignKey curFK = (ForeignKey)curTable.getFks().get(k);
+				String pkTableName = curFK.getForeignTableName();
+				
+				if(pkTofkTable.get(pkTableName) == null) {
+					pkTofkTable.put(pkTableName, new ArrayList());
+				}
+				((ArrayList)pkTofkTable.get(pkTableName)).add(curTable.getName());
+			}
+		}
+		
+		String srcCode = startLine;
+		
+		for(int i=0; i<dbSchema.getTables().size(); i++) {
+			Table curTable = (Table)dbSchema.getTables().get(i);
+			srcCode = srcCode + "<xsd:complexType name=\""+curTable.getName()+"\">\n";
+			srcCode = srcCode + "   <xsd:sequence>\n";
+			
+			for(int j=0; j<curTable.getColumns().size(); j++) {
+				Column curColumn = (Column)curTable.getColumns().get(j);
+				srcCode = srcCode + "      <xsd:element name=\""+	curColumn.getName();
+				
+				if(curColumn.isRequired()) {
+					srcCode = srcCode + " nillable=\"false\"";
+				}
+				
+				Type sdoType = ResultSetTypeMap.INSTANCE.getType(SQLTypeChecker.getSQLTypeFromString(curColumn.getType()), true);
+				
+				srcCode = srcCode + " type=\"xsd:"+SQLTypeChecker.xsdTypeForSDOType(sdoType.getName())+"\"/>\n";
+			}
+			
+			if(pkTofkTable.get(curTable.getName()) != null) {
+				ArrayList fkTables = (ArrayList)pkTofkTable.get(curTable.getName());
+				
+				for(int k=0; k<fkTables.size(); k++) {
+					srcCode = srcCode + "      <xsd:element maxOccurs=\"unbounded\" name=\""+ fkTables.get(k)+"\" type=\"this:"+fkTables.get(k)+"\"/>\n";
+				}
+			}
+			
+			srcCode = srcCode + "   </xsd:sequence>\n";
+			srcCode = srcCode + "</xsd:complexType>\n\n";
+		}
+		
+		srcCode = srcCode + endLine;
+
+		File javaFile = new File(xsdModelFileName);
+		javaFile.createNewFile();
+		PrintStream flStrm = new PrintStream(javaFile);
+		
+		if(writeFilesToDir) {
+			flStrm.print(srcCode);
+			flStrm.flush();
+			flStrm.close();
+		} else {
+			System.out.print(srcCode);
+		}
+	}	
+}
\ No newline at end of file
diff --git a/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Table.java b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Table.java
new file mode 100644
index 0000000000..c41085cf2f
--- /dev/null
+++ b/das-java/trunk/tools/src/main/java/org/apache/tuscany/das/rdb/util/Table.java
@@ -0,0 +1,66 @@
+/*
+ * 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.    
+ */
+package org.apache.tuscany.das.rdb.util;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class Table {
+	private String name;
+	private List columns = new ArrayList();
+	private List fks = new ArrayList();
+	
+	protected String getName() {
+		return name;
+	}
+	protected void setName(String name) {
+		this.name = name;
+	}
+	protected List getColumns() {
+		return columns;
+	}
+	protected void setColumns(List columns) {
+		this.columns = columns;
+	}
+	protected List getFks() {
+		return fks;
+	}
+	protected void setFks(List fks) {
+		this.fks = fks;
+	}
+	
+	public String toString() {
+		StringBuffer dbSchemaStr = new StringBuffer();
+		dbSchemaStr.append("_____Table_______"+this.name+"\n");
+		dbSchemaStr.append("_____Columns_______\n");
+		for(int i=0; i<this.columns.size(); i++) {
+			Column curColumn = (Column)this.columns.get(i);
+			dbSchemaStr.append(curColumn);
+		}
+		
+		if(this.fks.size() > 0)
+			dbSchemaStr.append("_____FKs_______\n");
+		for(int i=0; i<this.fks.size(); i++) {
+			ForeignKey curFk = (ForeignKey)this.fks.get(i);
+			dbSchemaStr.append(curFk);
+		}
+		
+		return dbSchemaStr.toString();
+	}	
+}
-- 
cgit v1.2.3