1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
/*
* 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.test.framework;
import java.sql.SQLException;
import junit.framework.Test;
public class MySQLSetup extends DatabaseSetup {
public MySQLSetup(Test test) {
super(test);
}
protected void initConnectionProtocol() {
platformName = "MySQL";
driverName = "com.mysql.jdbc.Driver";
databaseURL = "jdbc:mysql:///dastest?user=dastester&password=dastester";
}
protected void createProcedures() {
String createGetAllCompanies = "CREATE PROCEDURE `dastest`.`GETALLCOMPANIES` () "
+ " SELECT * FROM COMPANY ";
String createDeleteCustomer = "CREATE PROCEDURE `dastest`.`DELETECUSTOMER` (theId INT) "
+ " DELETE FROM CUSTOMER WHERE ID = theId ";
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 ";
String createGetCustomerAndOrders = " CREATE PROCEDURE `dastest`.`GETCUSTOMERANDORDERS` (theId INT) "
+ " SELECT * FROM CUSTOMER LEFT JOIN ANORDER ON CUSTOMER.ID = ANORDER.CUSTOMER_ID "
+ "WHERE CUSTOMER.ID = theId ";
String createGetNamedCompany = " CREATE PROCEDURE `dastest`.`GETNAMEDCOMPANY` (theName VARCHAR(100)) "
+ " SELECT * FROM COMPANY WHERE NAME = theName";
String createCustomersAndOrders = "CREATE PROCEDURE `dastest`.`GETALLCUSTOMERSANDORDERS` () "
+ " BEGIN SELECT * FROM CUSTOMER; SELECT * FROM ANORDER; END;";
System.out.println("Creating procedures");
try {
s.execute(createGetAllCompanies);
s.execute(createDeleteCustomer);
s.execute(createGetNamedCompany);
s.execute(createGetCustomerAndOrders);
s.execute(createGetNamedCustomers);
s.execute(createCustomersAndOrders);
} catch (SQLException e) {
throw new RuntimeException(e);
}
}
// Overrides for table creation
protected String getCreateCompany() {
return "CREATE TABLE COMPANY (ID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, NAME VARCHAR(30), EOTMID INT)";
}
protected String getCreateEmployee() {
return "CREATE TABLE EMPLOYEE (ID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, NAME VARCHAR(30), "
+ "SN VARCHAR(10), MANAGER SMALLINT, DEPARTMENTID INT)";
}
// protected String getCreateDepartment() {
// return "CREATE TABLE DEPARTMENT (ID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, NAME VARCHAR(30), "
// + "LOCATION VARCHAR(30), DEPNUMBER VARCHAR(10), COMPANYID INT, EOTM INT)";
// }
protected String getCreateTypeTest() {
return "CREATE TABLE TYPETEST (ID INT PRIMARY KEY NOT NULL, ATIMESTAMP DATETIME, ADECIMAL DECIMAL(9,2), "
+ "AFLOAT FLOAT)";
}
protected String getCreateServerStatus() {
return "CREATE TABLE CONMGT.SERVERSTATUS (STATUSID INT PRIMARY KEY NOT NULL AUTO_INCREMENT, "
+ "MANAGEDSERVERID INTEGER NOT NULL, TIMESTAMP TIMESTAMP NOT NULL)";
}
protected String getGeneratedKeyClause() {
return "AUTO_INCREMENT";
}
}
|
