diff options
Diffstat (limited to 'das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org')
5 files changed, 915 insertions, 0 deletions
diff --git a/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/customer/CustomerClient.java b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/customer/CustomerClient.java new file mode 100644 index 0000000000..ca66c5bf4f --- /dev/null +++ b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/customer/CustomerClient.java @@ -0,0 +1,197 @@ +/*
+ * 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.samples.das.customer;
+
+import java.io.InputStream;
+import java.util.List;
+
+import org.apache.tuscany.das.rdb.Command;
+import org.apache.tuscany.das.rdb.DAS;
+
+import commonj.sdo.DataObject;
+
+public class CustomerClient {
+ private static final String DEFAULT_CUSTOMER_CONFIG = "CustomersConfig.xml";
+
+ private DAS das = null;
+ private final String configFile;
+
+ /**
+ * Default constructor
+ *
+ */
+ public CustomerClient(){
+ this.configFile = DEFAULT_CUSTOMER_CONFIG;
+ }
+
+ /**
+ * Constructor receiving the das config file to be used
+ * @param configFile DAS configuration file
+ */
+ public CustomerClient(String configFile) {
+ this.configFile = configFile;
+ }
+
+ /**
+ * Helper method to get a stream from the customer config file
+ * @param fileName
+ * @return
+ */
+ protected InputStream getConfig(String fileName) {
+ return getClass().getClassLoader().getResourceAsStream(fileName);
+ }
+
+ /**
+ * Get a reference to DAS, initialize it if necessary
+ * @return DAS reference
+ */
+ protected DAS getDAS() {
+ if (this.das == null ) {
+ this.das = DAS.FACTORY.createDAS(getConfig(this.configFile));
+ }
+ return this.das;
+ }
+
+
+ /**
+ * select
+ * @return
+ */
+ public final List getCustomers() {
+ Command read = this.getDAS().getCommand("AllCustomers");
+ DataObject root = read.executeQuery();
+ return root.getList("CUSTOMER");
+ }
+
+ /**
+ * insert
+ *
+ */
+ public final void addCustomer() {
+ Command read = this.getDAS().getCommand("AllCustomers");
+ DataObject root = read.executeQuery();
+
+ DataObject newCustomer = root.createDataObject("CUSTOMER");
+ newCustomer.setInt("ID", 5);
+ newCustomer.setString("LASTNAME", "Jenny");
+ newCustomer.setString("ADDRESS", "USA");
+
+ das.applyChanges(root);
+ }
+
+ /**
+ * delete
+ *
+ */
+ public final void deleteCustomer() {
+ Command readAll = this.getDAS().getCommand("AllCustomers");
+ DataObject root = readAll.executeQuery();
+
+ List allCustomers = root.getList("CUSTOMER");
+
+ DataObject lastCustomer = (DataObject)allCustomers.get(allCustomers.size()-1);
+ if(lastCustomer != null){
+ System.out.println("Deleting customer named: " + lastCustomer.getString("LASTNAME"));
+ lastCustomer.delete();
+ }
+
+ das.applyChanges(root);
+ }
+
+ /**
+ * update
+ *
+ */
+ public final void changeFirstCustomerName() {
+ Command readAll = this.getDAS().getCommand("AllCustomers");
+ DataObject root = readAll.executeQuery();
+
+ DataObject firstCustomer = root.getDataObject("CUSTOMER[1]");
+ firstCustomer.set("LASTNAME", "BlueBerry");
+
+ das.applyChanges(root);
+ }
+
+ /**
+ * display result
+ * @param customers
+ */
+ public static void printList(List customers){
+ for(int i=0; i<customers.size(); i++){
+ System.out.println(" ID:"+(((DataObject)customers.get(i)).getInt("ID"))+
+ " LASTNAME:"+(((DataObject)customers.get(i)).getString("LASTNAME"))+
+ " ADDRESS:"+(((DataObject)customers.get(i)).getString("ADDRESS")));
+ }
+ }
+
+ /**
+ * cleanup
+ *
+ */
+ public void releaseResources() {
+ das.releaseResources();
+ }
+
+ /**
+ * Main customer application
+ */
+ public static void main(String[] args){
+ String customerConfigFile = "CustomersConfig.xml"; //this can be from input params too as below
+
+ if(args != null && args.length >0){
+ customerConfigFile = args[0];
+ }
+
+
+ //initialize customer database using helper class
+ CustomerDatabaseInitializer dbInitializer = new CustomerDatabaseInitializer(customerConfigFile);
+ try {
+ dbInitializer.Initialize();
+ } catch (Exception e) {
+ e.printStackTrace();
+ return;
+ }
+
+
+ //perform customer operations using DAS
+ CustomerClient customerClient = new CustomerClient(customerConfigFile);
+ //test select
+ System.out.println();
+ System.out.println("Result:select all customers");
+ printList(customerClient.getCustomers());
+
+ //test insert
+ System.out.println();
+ System.out.println("Result:insert new customer");
+ customerClient.addCustomer();
+ printList(customerClient.getCustomers());
+
+ //test update
+ System.out.println();
+ System.out.println("Result:update first customer");
+ customerClient.changeFirstCustomerName();
+ printList(customerClient.getCustomers());
+
+ //test delete
+ System.out.println();
+ System.out.println("Result:delete last customer");
+ customerClient.deleteCustomer();
+ printList(customerClient.getCustomers());
+ }
+}
\ No newline at end of file diff --git a/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/customer/CustomerDatabaseInitializer.java b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/customer/CustomerDatabaseInitializer.java new file mode 100644 index 0000000000..260fc330fd --- /dev/null +++ b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/customer/CustomerDatabaseInitializer.java @@ -0,0 +1,92 @@ +/* + * 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.samples.das.customer; + +import org.apache.tuscany.das.rdb.config.Config; +import org.apache.tuscany.das.rdb.util.ConfigUtil; +import org.apache.tuscany.samples.das.databaseSetup.DerbySetup; +import org.apache.tuscany.samples.das.databaseSetup.MySQLSetup; + +public class CustomerDatabaseInitializer { + public static final String DERBY = "derby"; + public static final String MYSQL = "mysql"; + + private final Config config; + + private final String dbType; + private final String dbURL; + private final String user; + private final String password; + + + + public CustomerDatabaseInitializer(String configFile) { + this.config = ConfigUtil.loadConfig(this.getClass().getClassLoader().getResourceAsStream(configFile)); + + if(config.getConnectionInfo().getConnectionProperties().getDriverClass().indexOf(DERBY) != -1) { + dbType = DERBY; + } else if(config.getConnectionInfo().getConnectionProperties().getDriverClass().indexOf(MYSQL) != -1) { + dbType = MYSQL; + } else { + dbType = null; + } + + //get connection info from config + dbURL = config.getConnectionInfo().getConnectionProperties().getDatabaseURL(); + user = config.getConnectionInfo().getConnectionProperties().getUserName(); + password = config.getConnectionInfo().getConnectionProperties().getPassword(); + } + + + + /** + * If database is present connect to it and create necessary tables, procedures, data etc. + * If database is not present create database and then create the above elements. Create database + * is implemented for MySQL and Derby. + */ + public void Initialize() { + + //display DB configuration iformation + DisplayDatabaseConfiguration(); + + //initialize DB + try { + if(dbType.equals(DERBY)){ + new DerbySetup(dbURL+"-"+user+"-"+password); + } + + if(dbType.equals(MYSQL)){ + new MySQLSetup(dbURL+"-"+user+"-"+password); + } + + } catch(Exception e){ + throw new RuntimeException("Error initializing database !", e); + } + } + + public void DisplayDatabaseConfiguration() { + + System.out.println("************* Initializing database *************"); + System.out.println("** DB type : " + dbType ); + System.out.println("** Database : " + dbURL ); + System.out.println("** User : " + user ); + System.out.println("** Password : " + password); + System.out.println("************************************************"); + } +} diff --git a/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetup.java b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetup.java new file mode 100644 index 0000000000..4195dbcac7 --- /dev/null +++ b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetup.java @@ -0,0 +1,206 @@ +/*
+ * 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.samples.das.databaseSetup;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.Properties;
+import java.util.StringTokenizer;
+
+public class DatabaseSetup{
+ protected Statement s;
+ protected String platformName = "Not initialized";
+ protected String driverName = "Not initialized";
+ protected String databaseURL = "Not initialized";
+ protected String databaseName = null;
+ protected String userName;
+ protected String password;
+
+ // Data Types
+ public static final String stringType = "VARCHAR";
+ public static final String integerType = "INT";
+ public static final String timestampType = "TIMESTAMP";
+ public static final String floatType = "FLOAT";
+ public static final String decimalType = "DECIMAL";
+ protected Connection connection;
+
+ //database types
+ public static final String DERBY = "derby";
+ public static final String MYSQL = "mysql";
+ public static final String DB2 = "db2";
+
+ public DatabaseSetup(String databaseInfo){
+ StringTokenizer strTok = new StringTokenizer(databaseInfo, "-");
+
+ if(strTok.hasMoreTokens()){
+ databaseName = strTok.nextToken();
+ }
+
+ if(strTok.hasMoreTokens()){
+ userName = strTok.nextToken();
+ }
+
+ if(strTok.hasMoreTokens()){
+ password = strTok.nextToken();
+ }
+
+ initConnectionProtocol(databaseName);
+ initConnection();
+ try{
+ this.setUp();
+ }catch(Exception e){
+ e.printStackTrace();
+ }
+ }
+
+ protected void initConnectionProtocol( String databaseName){
+ }
+
+ private void initConnection() {
+
+ try {
+ Class.forName(driverName).newInstance();
+ Properties props = new Properties();
+ //System.out.println("platform name:"+this.platformName);
+
+ if(this.platformName.equals(DERBY)){
+ if (userName != null) {
+ //System.out.println("derby trying for "+userName+","+password+","+databaseURL);
+ connection = DriverManager.getConnection(databaseURL, userName, password);
+ } else {
+ //System.out.println("derby trying for "+databaseURL);
+ connection = DriverManager.getConnection(databaseURL);
+ }
+ }
+ if(this.platformName.equals(DB2)){
+ if (userName != null && password != null) {
+ props.put("user", userName);
+ props.put("password", password);
+
+ //System.out.println("db2 trying for "+databaseURL+"user,pwd"+userName+","+password);
+ connection = DriverManager.getConnection(databaseURL, props);
+ }else{
+ //System.out.println("db2 trying for "+databaseURL);
+ connection = DriverManager.getConnection(databaseURL);
+ }
+ }
+ if(this.platformName.equals(MYSQL)){
+ databaseURL=databaseURL+"?user="+userName+"&password="+password+"&createDatabaseIfNotExist="+"true";
+ //System.out.println("mysql trying for "+userName+","+password+","+databaseURL);
+ connection = DriverManager.getConnection(databaseURL, props);
+ }
+
+ connection.setAutoCommit(true);
+ } catch (SQLException e) {
+ e.printStackTrace();
+ if (e.getNextException() != null) {
+ e.getNextException().printStackTrace();
+ } else {
+ e.printStackTrace();
+ }
+
+ throw new RuntimeException(e);
+ } catch (IllegalAccessException e) {
+ e.printStackTrace();
+ throw new RuntimeException(e);
+ } catch (InstantiationException e) {
+ e.printStackTrace();
+ throw new RuntimeException(e);
+ } catch (ClassNotFoundException e) {
+ e.printStackTrace();
+ throw new RuntimeException(e);
+ }
+ }
+
+ public Connection getConnection(){
+ return this.connection;
+ }
+
+ protected void setUp() throws Exception {
+ System.out.println("Setting up for " + platformName + " run!");
+ }
+
+ private void insertData(){
+ }
+
+ private void dropTables() {
+ }
+
+ protected void dropTriggers() {
+ }
+
+ protected void createTriggers() {
+ }
+
+ protected void dropSequences() {
+ }
+
+ protected void createSequences() {
+ }
+
+ protected void dropProcedures() {
+ }
+
+ private void createTables() {
+ }
+
+ protected void createProcedures() {
+ }
+
+ //
+ // This section povides methods that return strings for table creation.
+ // Platform-specific sublcasses
+ // can override these as necessary
+ //
+
+ protected String getCreateCustomer() {
+ return null;
+ }
+ // /////////////////
+
+ protected String getForeignKeyConstraint(String pkTable, String pkColumn, String foreignKey) {
+ return null;
+ }
+
+ protected String getStringColumn(String name, int length) {
+ return null;
+ }
+
+ protected String getIntegerColumn(String name) {
+ return null;
+ }
+
+ protected String getGeneratedKeyClause() {
+ return null;
+ }
+
+ protected String getDecimalColumn(String name, int size1, int size2) {
+ return null;
+ }
+
+ protected String getFloatColumn(String name) {
+ return null;
+ }
+
+ protected String getTimestampColumn(String name) {
+ return null;
+ }
+}
\ No newline at end of file diff --git a/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DerbySetup.java b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DerbySetup.java new file mode 100644 index 0000000000..339cac3587 --- /dev/null +++ b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DerbySetup.java @@ -0,0 +1,209 @@ +/*
+ * 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.samples.das.databaseSetup;
+
+import java.sql.SQLException;
+
+public class DerbySetup extends DatabaseSetup {
+
+ public DerbySetup(String databaseInfo){
+ super(databaseInfo);
+ }
+
+ protected void initConnectionProtocol(String databaseURL){
+ this.platformName=DERBY;
+ this.driverName = "org.apache.derby.jdbc.EmbeddedDriver";
+ this.databaseURL = databaseURL;
+ }
+
+ public void setUp(){
+ try{
+ super.setUp();
+
+ try {
+ s = connection.createStatement();
+
+ dropTriggers();
+ dropSequences();
+ dropTables();
+ dropProcedures();
+
+ createSequences();
+ createTables();
+ createTriggers();
+ createProcedures();
+ connection.commit();
+
+ insertData();
+ connection.commit();
+ } catch (SQLException e) {
+ connection.rollback();
+ }
+ }catch(Exception e){
+ e.printStackTrace();
+ }
+
+ System.out.println("Database setup complete!");
+ }
+
+ private void insertData(){
+ System.out.println("Inserting data in tables");
+
+ String[] statements = {"INSERT INTO CUSTOMER VALUES (1,'John','USA')",
+ "INSERT INTO CUSTOMER VALUES (2,'Amita','INDIA')",
+ "INSERT INTO CUSTOMER VALUES (3,'Patrick','UK')",
+ "INSERT INTO CUSTOMER VALUES (4,'Jane','UN')"};
+
+ for (int i = 0; i < statements.length; i++) {
+ try {
+ s.execute(statements[i]);
+ } catch (SQLException e) {
+ // If the table does not exist then ignore the exception on drop
+ if ((!(e.getMessage().indexOf("does not exist") >= 0)) && (!(e.getMessage().indexOf("Unknown table") >= 0))
+ && (!(e.getMessage().indexOf("42704") >= 0))) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+ }
+
+ private void dropTables() {
+ System.out.println("Dropping tables");
+ String[] statements = {"DROP TABLE CUSTOMER" };
+
+ for (int i = 0; i < statements.length; i++) {
+ try {
+ s.execute(statements[i]);
+ } catch (SQLException e) {
+ // If the table does not exist then ignore the exception on drop
+ if ((!(e.getMessage().indexOf("does not exist") >= 0)) && (!(e.getMessage().indexOf("Unknown table") >= 0))
+ && (!(e.getMessage().indexOf("42704") >= 0))) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+ }
+
+ protected void dropTriggers() {
+
+ }
+
+ protected void createTriggers() {
+
+ }
+
+ protected void dropSequences() {
+
+ }
+
+ protected void createSequences() {
+
+ }
+
+ protected void dropProcedures() {
+
+ System.out.println("Dropping procedures");
+
+ String[] statements = {"DROP PROCEDURE GETNAMEDCUSTOMERS"};
+
+ for (int i = 0; i < statements.length; i++) {
+ try {
+ s.execute(statements[i]);
+ } catch (SQLException e) {
+ // If the proc does not exist then ignore the exception on drop
+ if (!(e.getMessage().indexOf("does not exist") >= 0) && !(e.getMessage().indexOf("42704") >= 0)) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+ }
+
+ private void createTables() {
+ System.out.println("Creating tables");
+
+ try {
+ s.execute(getCreateCustomer());
+ } catch (SQLException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ protected void createProcedures() {
+
+ System.out.println("Creating procedures");
+ try {
+
+ s.execute("CREATE PROCEDURE GETNAMEDCUSTOMERS(theName VARCHAR(100), OUT theCount INTEGER) "
+ + "PARAMETER STYLE JAVA LANGUAGE JAVA READS SQL DATA DYNAMIC RESULT SETS 1 EXTERNAL NAME "
+ + "'org.apache.tuscany.samples.das.orders.MyStoredProcs.getNamedCustomers'");
+ } catch (SQLException e) {
+ e.printStackTrace();
+ throw new RuntimeException(e);
+ }
+ }
+
+ //
+ // This section povides methods that return strings for table creation.
+ // Platform-specific sublcasses
+ // can override these as necessary
+ //
+
+ protected String getCreateCustomer() {
+ return "CREATE TABLE CUSTOMER (" + getIntegerColumn("ID") + " PRIMARY KEY NOT NULL, "
+ + getStringColumn("LASTNAME", 30)
+ + " DEFAULT 'Garfugengheist', " + getStringColumn("ADDRESS", 30) + ")";
+ }
+
+ protected String getForeignKeyConstraint(String pkTable, String pkColumn, String foreignKey) {
+ StringBuffer buffer = new StringBuffer();
+ buffer.append("CONSTRAINT FK1 FOREIGN KEY (");
+ buffer.append(foreignKey);
+ buffer.append(") REFERENCES ");
+ buffer.append(pkTable);
+ buffer.append("(");
+ buffer.append(pkColumn);
+ buffer.append(") ON DELETE NO ACTION ON UPDATE NO ACTION");
+ return buffer.toString();
+ }
+
+ protected String getStringColumn(String name, int length) {
+ return name + ' ' + stringType + "(" + new Integer(length).toString() + ")";
+ }
+
+ protected String getIntegerColumn(String name) {
+ return name + ' ' + integerType;
+ }
+
+ protected String getGeneratedKeyClause() {
+ return "GENERATED ALWAYS AS IDENTITY";
+ }
+
+ protected String getDecimalColumn(String name, int size1, int size2) {
+ return name + ' ' + decimalType + "(" + new Integer(size1).toString() + ','
+ + new Integer(size2).toString() + ")";
+ }
+
+ protected String getFloatColumn(String name) {
+ return name + ' ' + floatType;
+ }
+
+ protected String getTimestampColumn(String name) {
+ return name + ' ' + timestampType;
+ }
+}
diff --git a/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/MySQLSetup.java b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/MySQLSetup.java new file mode 100644 index 0000000000..f64b16e2db --- /dev/null +++ b/das-java/tags/1.0-incubating-beta2-rc1/samples/customer/src/main/java/org/apache/tuscany/samples/das/databaseSetup/MySQLSetup.java @@ -0,0 +1,211 @@ +/*
+ * 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.samples.das.databaseSetup;
+
+import java.sql.SQLException;
+
+public class MySQLSetup extends DatabaseSetup {
+
+ public MySQLSetup(String databaseInfo){
+ super(databaseInfo);
+ }
+
+ protected void initConnectionProtocol(String databaseURL){
+ this.platformName=MYSQL;
+ this.driverName = "com.mysql.jdbc.Driver";
+ this.databaseURL = databaseURL;
+ }
+
+ public void setUp(){
+ try{
+ super.setUp();
+
+ try {
+ s = connection.createStatement();
+
+ dropTriggers();
+ dropSequences();
+ dropTables();
+ dropProcedures();
+
+ createSequences();
+ createTables();
+ createTriggers();
+ createProcedures();
+ insertData();
+ } catch (SQLException e) {
+ e.printStackTrace();
+ }
+ }catch(Exception e){
+ e.printStackTrace();
+ }
+
+ System.out.println("Database setup complete!");
+ }
+
+ private void insertData(){
+ System.out.println("Inserting data in tables");
+
+ String[] statements = {"INSERT INTO CUSTOMER VALUES (1,'John','USA')",
+ "INSERT INTO CUSTOMER VALUES (2,'Amita','INDIA')",
+ "INSERT INTO CUSTOMER VALUES (3,'Patrick','UK')",
+ "INSERT INTO CUSTOMER VALUES (4,'Jane','UN')"};
+
+ for (int i = 0; i < statements.length; i++) {
+ try {
+ s.execute(statements[i]);
+ } catch (SQLException e) {
+ // If the table does not exist then ignore the exception on drop
+ if ((!(e.getMessage().indexOf("does not exist") >= 0)) && (!(e.getMessage().indexOf("Unknown table") >= 0))
+ && (!(e.getMessage().indexOf("42704") >= 0))) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+ }
+
+ private void dropTables() {
+ System.out.println("Dropping tables");
+
+ String[] statements = {"DROP TABLE CUSTOMER"};
+
+ for (int i = 0; i < statements.length; i++) {
+ try {
+ s.execute(statements[i]);
+ } catch (SQLException e) {
+ // If the table does not exist then ignore the exception on drop
+ if ((!(e.getMessage().indexOf("does not exist") >= 0)) && (!(e.getMessage().indexOf("Unknown table") >= 0))
+ && (!(e.getMessage().indexOf("42704") >= 0))) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+ }
+
+ protected void dropTriggers() {
+
+ }
+
+ protected void createTriggers() {
+
+ }
+
+ protected void dropSequences() {
+
+ }
+
+ protected void createSequences() {
+
+ }
+
+ protected void dropProcedures() {
+
+ System.out.println("Dropping procedures");
+
+ String[] statements = {"DROP PROCEDURE GETNAMEDCUSTOMERS"};
+
+ for (int i = 0; i < statements.length; i++) {
+ try {
+ s.execute(statements[i]);
+ } catch (SQLException e) {
+ // If the proc does not exist then ignore the exception on drop
+ if (!(e.getMessage().indexOf("does not exist") >= 0) && !(e.getMessage().indexOf("42704") >= 0)) {
+ throw new RuntimeException(e);
+ }
+ }
+ }
+ }
+
+ private void createTables() {
+ System.out.println("Creating tables");
+
+ try {
+
+ s.execute(getCreateCustomer());
+
+ } catch (SQLException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ //
+ // This section povides methods that return strings for table creation.
+ // Platform-specific sublcasses
+ // can override these as necessary
+ //
+
+ protected String getCreateCustomer() {
+ return "CREATE TABLE CUSTOMER (" + getIntegerColumn("ID") + " PRIMARY KEY NOT NULL, "
+ + getStringColumn("LASTNAME", 30)
+ + " DEFAULT 'Garfugengheist', " + getStringColumn("ADDRESS", 30) + ")";
+ }
+
+ // /////////////////
+
+ protected String getForeignKeyConstraint(String pkTable, String pkColumn, String foreignKey) {
+ StringBuffer buffer = new StringBuffer();
+ buffer.append("CONSTRAINT FK1 FOREIGN KEY (");
+ buffer.append(foreignKey);
+ buffer.append(") REFERENCES ");
+ buffer.append(pkTable);
+ buffer.append("(");
+ buffer.append(pkColumn);
+ buffer.append(") ON DELETE NO ACTION ON UPDATE NO ACTION");
+ return buffer.toString();
+ }
+
+ protected String getStringColumn(String name, int length) {
+ return name + ' ' + stringType + "(" + new Integer(length).toString() + ")";
+ }
+
+ protected String getIntegerColumn(String name) {
+ return name + ' ' + integerType;
+ }
+
+ protected String getDecimalColumn(String name, int size1, int size2) {
+ return name + ' ' + decimalType + "(" + new Integer(size1).toString() + ','
+ + new Integer(size2).toString() + ")";
+ }
+
+ protected String getFloatColumn(String name) {
+ return name + ' ' + floatType;
+ }
+
+ protected String getTimestampColumn(String name) {
+ return name + ' ' + timestampType;
+ }
+
+ protected void createProcedures() {
+ String createGetNamedCustomers = "CREATE PROCEDURE `dastest`.`GETNAMEDCUSTOMERS`(IN thename VARCHAR(30), "
+ + "OUT theCount INTEGER ) " + " BEGIN "
+ + " SELECT * FROM CUSTOMER AS CUSTOMER WHERE LASTNAME = theName; "
+ + " SET theCount = (SELECT COUNT(*) FROM CUSTOMER WHERE LASTNAME = theName); " + " END ";
+
+ System.out.println("Creating procedures");
+ try {
+ s.execute(createGetNamedCustomers);
+ } catch (SQLException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ protected String getGeneratedKeyClause() {
+ return "AUTO_INCREMENT";
+ }
+}
|