You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by lr...@apache.org on 2008/08/11 06:46:18 UTC
svn commit: r684630 -
/tuscany/sandbox/lresende/sca/samples/organization-das/src/main/java/organization/das/OrganizationDataServiceImpl.java
Author: lresende
Date: Sun Aug 10 21:46:18 2008
New Revision: 684630
URL: http://svn.apache.org/viewvc?rev=684630&view=rev
Log:
Updating das configuration file name in sample application
Modified:
tuscany/sandbox/lresende/sca/samples/organization-das/src/main/java/organization/das/OrganizationDataServiceImpl.java
Modified: tuscany/sandbox/lresende/sca/samples/organization-das/src/main/java/organization/das/OrganizationDataServiceImpl.java
URL: http://svn.apache.org/viewvc/tuscany/sandbox/lresende/sca/samples/organization-das/src/main/java/organization/das/OrganizationDataServiceImpl.java?rev=684630&r1=684629&r2=684630&view=diff
==============================================================================
--- tuscany/sandbox/lresende/sca/samples/organization-das/src/main/java/organization/das/OrganizationDataServiceImpl.java (original)
+++ tuscany/sandbox/lresende/sca/samples/organization-das/src/main/java/organization/das/OrganizationDataServiceImpl.java Sun Aug 10 21:46:18 2008
@@ -19,44 +19,24 @@
package organization.das;
import java.io.InputStream;
-import java.sql.Connection;
-import java.sql.DriverManager;
import org.apache.tuscany.das.rdb.Command;
import org.apache.tuscany.das.rdb.DAS;
import org.soa.types.SchemaInfoType;
+import util.ConnectionHelper;
+
import commonj.sdo.DataObject;
public class OrganizationDataServiceImpl implements OrganizationDataService {
-
- private java.sql.Connection getConnection(SchemaInfoType schemaInfo)
- {
- Connection conn = null;
-
- // schemaInfo should be your SID. Something like xe (for Oracle Personal Edition)
- String url = "jdbc:derby:target/dastest; create = true";
- String driver = "org.apache.derby.jdbc.EmbeddedDriver";
-
- try {
- Class.forName(driver);
- conn = DriverManager.getConnection(url, schemaInfo.getUSERNAME(), schemaInfo.getPASSWORD());
- conn.setAutoCommit(false);
- }
- catch (Exception e) {
- e.printStackTrace();
- }
-
- return conn;
- }
public DataObject findOrganizationBugTwo(String id, SchemaInfoType schemaInfo) {
DataObject root = null;
- InputStream in = getClass().getClassLoader().getResourceAsStream("dasConfiguration.xml");
+ InputStream in = getClass().getClassLoader().getResourceAsStream("organizationConfiguration.xml");
- java.sql.Connection conn = getConnection(schemaInfo);
+ java.sql.Connection conn = ConnectionHelper.getConnection(schemaInfo);
DAS das = DAS.FACTORY.createDAS(in, conn);
Command read = das.getCommand("getAccountByID");
@@ -71,9 +51,9 @@
public DataObject findOrganizationBugOne(String id, SchemaInfoType schemaInfo) {
DataObject root = null;
- InputStream in = getClass().getClassLoader().getResourceAsStream("dasConfiguration.xml");
+ InputStream in = getClass().getClassLoader().getResourceAsStream("organizationConfiguration.xml");
- java.sql.Connection conn = getConnection(schemaInfo);
+ java.sql.Connection conn = ConnectionHelper.getConnection(schemaInfo);
DAS das = DAS.FACTORY.createDAS(in, conn);
Command read = das.getCommand("getAccountByID");
@@ -95,9 +75,9 @@
}
public void updateOrganization(DataObject organization, SchemaInfoType schemaInfo) {
- InputStream in = getClass().getClassLoader().getResourceAsStream("dasConfiguration.xml");
+ InputStream in = getClass().getClassLoader().getResourceAsStream("organizationConfiguration.xml");
- java.sql.Connection conn = getConnection(schemaInfo);
+ java.sql.Connection conn = ConnectionHelper.getConnection(schemaInfo);
DAS das = DAS.FACTORY.createDAS(in, conn);