KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > juddi > datastore > jdbc > BusinessNameTable


1 /*
2  * Copyright 2001-2004 The Apache Software Foundation.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package org.apache.juddi.datastore.jdbc;
17
18 import java.sql.Connection JavaDoc;
19 import java.sql.PreparedStatement JavaDoc;
20 import java.sql.ResultSet JavaDoc;
21 import java.util.Vector JavaDoc;
22
23 import org.apache.commons.logging.Log;
24 import org.apache.commons.logging.LogFactory;
25 import org.apache.juddi.datatype.Name;
26
27 /**
28  * @author Steve Viens (sviens@apache.org)
29  */
30 class BusinessNameTable
31 {
32   // private reference to the jUDDI logger
33 private static Log log = LogFactory.getLog(BusinessNameTable.class);
34
35   static String JavaDoc insertSQL = null;
36   static String JavaDoc selectSQL = null;
37   static String JavaDoc deleteSQL = null;
38
39   static {
40     // buffer used to build SQL statements
41 StringBuffer JavaDoc sql = null;
42
43     // build insertSQL
44 sql = new StringBuffer JavaDoc(150);
45     sql.append("INSERT INTO BUSINESS_NAME (");
46     sql.append("BUSINESS_KEY,");
47     sql.append("BUSINESS_NAME_ID,");
48     sql.append("LANG_CODE,");
49     sql.append("NAME) ");
50     sql.append("VALUES (?,?,?,?)");
51     insertSQL = sql.toString();
52
53     // build selectSQL
54 sql = new StringBuffer JavaDoc(200);
55     sql.append("SELECT ");
56     sql.append("LANG_CODE,");
57     sql.append("NAME, ");
58     sql.append("BUSINESS_NAME_ID ");
59     sql.append("FROM BUSINESS_NAME ");
60     sql.append("WHERE BUSINESS_KEY=? ");
61     sql.append("ORDER BY BUSINESS_NAME_ID");
62     selectSQL = sql.toString();
63
64     // build deleteSQL
65 sql = new StringBuffer JavaDoc(100);
66     sql.append("DELETE FROM BUSINESS_NAME ");
67     sql.append("WHERE BUSINESS_KEY=?");
68     deleteSQL = sql.toString();
69   }
70
71   /**
72    * Insert new row into the BUSINESS_NAME table.
73    *
74    * @param businessKey String to the BusinessEntity object that owns the Contact to be inserted
75    * @param nameList Vector of Phone objects holding values to be inserted
76    * @param connection JDBC connection
77    * @throws java.sql.SQLException
78    */
79   public static void insert(
80     String JavaDoc businessKey,
81     Vector JavaDoc nameList,
82     Connection JavaDoc connection)
83     throws java.sql.SQLException JavaDoc
84   {
85     if ((nameList == null) || (nameList.size() == 0))
86       return; // everything is valid but no elements to insert
87
88     PreparedStatement JavaDoc statement = null;
89
90     try
91     {
92       statement = connection.prepareStatement(insertSQL);
93       statement.setString(1, businessKey.toString());
94
95       int listSize = nameList.size();
96       for (int nameID = 0; nameID < listSize; nameID++)
97       {
98         Name name = (Name) nameList.elementAt(nameID);
99
100         statement.setInt(2, nameID);
101         statement.setString(3, name.getLanguageCode());
102         statement.setString(4, name.getValue());
103
104         log.debug(
105           "insert into BUSINESS_NAME table:\n\n\t"
106             + insertSQL
107             + "\n\t BUSINESS_KEY="
108             + businessKey.toString()
109             + "\n\t BUSINESS_NAME_ID="
110             + nameID
111             + "\n\t LANG_CODE="
112             + name.getLanguageCode()
113             + "\n\t NAME="
114             + name.getValue()
115             + "\n");
116
117         statement.executeUpdate();
118       }
119     }
120     finally
121     {
122       try
123       {
124         statement.close();
125       }
126       catch (Exception JavaDoc e)
127       { /* ignored */
128       }
129     }
130   }
131
132   /**
133    * Select all rows from the BUSINESS_NAME table for a given BusinessKey.
134    *
135    * @param businessKey String
136    * @param connection JDBC connection
137    * @throws java.sql.SQLException
138    */
139   public static Vector JavaDoc select(String JavaDoc businessKey, Connection JavaDoc connection)
140     throws java.sql.SQLException JavaDoc
141   {
142     Vector JavaDoc nameList = new Vector JavaDoc();
143     PreparedStatement JavaDoc statement = null;
144     ResultSet JavaDoc resultSet = null;
145
146     try
147     {
148       // create a statement to query with
149 statement = connection.prepareStatement(selectSQL);
150       statement.setString(1, businessKey.toString());
151
152       log.debug(
153         "select from the BUSINESS_NAME table:\n\n\t"
154           + selectSQL
155           + "\n\t BUSINESS_KEY="
156           + businessKey.toString()
157           + "\n");
158
159       // execute the statement
160 resultSet = statement.executeQuery();
161       while (resultSet.next())
162       {
163         Name name = new Name();
164         name.setValue(resultSet.getString(2));//("NAME"));
165 name.setLanguageCode(resultSet.getString(1));//("LANG_CODE"));
166 nameList.add(name);
167       }
168
169       return nameList;
170     }
171     finally
172     {
173       try
174       {
175         resultSet.close();
176         statement.close();
177       }
178       catch (Exception JavaDoc e)
179       { /* ignored */
180       }
181     }
182   }
183
184   /**
185    * Delete multiple rows from the BUSINESS_NAME table that are assigned
186    * to the BusinessKey specified.
187    *
188    * @param businessKey String
189    * @param connection JDBC connection
190    * @throws java.sql.SQLException
191    */
192   public static void delete(String JavaDoc businessKey, Connection JavaDoc connection)
193     throws java.sql.SQLException JavaDoc
194   {
195     PreparedStatement JavaDoc statement = null;
196
197     try
198     {
199       // prepare the delete
200 statement = connection.prepareStatement(deleteSQL);
201       statement.setString(1, businessKey.toString());
202
203       log.debug(
204         "delete from the BUSINESS_NAME table:\n\n\t"
205           + deleteSQL
206           + "\n\t BUSINESS_KEY="
207           + businessKey.toString()
208           + "\n");
209
210       // execute
211 statement.executeUpdate();
212     }
213     finally
214     {
215       try
216       {
217         statement.close();
218       }
219       catch (Exception JavaDoc e)
220       { /* ignored */
221       }
222     }
223   }
224 }
225
Popular Tags