KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > teamkonzept > webman > mainint > db > queries > DeleteStrucContentValue


1 package com.teamkonzept.webman.mainint.db.queries;
2
3 import java.sql.*;
4
5 import com.teamkonzept.db.*;
6 import com.teamkonzept.webman.mainint.db.queries.sitetree.DeleteFromContentValue;
7 import com.teamkonzept.webman.mainint.db.queries.sitetree.DeleteFromContentNode;
8
9 /**
10  * @author $Author: ralf $
11  * @version $Revision: 1.1 $
12 */
13 public class DeleteStrucContentValue extends TKExtendedPrepQuery
14 {
15     public final static boolean IS_PREPARED =
16         true;
17     
18     public final static String JavaDoc[] PARAM_ORDER =
19         {
20             "CONTENT_ID", "CONTENT_ID"
21         };
22     
23     public final static Object JavaDoc[][] PARAM_TYPES =
24         null;
25     
26     public final static boolean[] SET_RELEVANTS =
27         null;
28         
29     public final static String JavaDoc SQL_STRING =
30             " DELETE FROM CONTENT_VALUE WHERE CONTENT_ID = ? " +
31             " DELETE FROM CONTENT_NODE " +
32             " WHERE CONTENT_ID = ? " ;
33     
34     protected static Class JavaDoc[] queryClasses = {
35         DeleteFromContentValue.class, // [0]
36 DeleteFromContentNode.class // [1]
37 };
38
39     public boolean execute()
40     {
41         try
42         {
43             init(queryClasses); // init query objects
44
45                     
46             Integer JavaDoc nodeId = (Integer JavaDoc) queryParams.get("CONTENT__ID");
47             
48             boolean isNotOpen = aTKDBConnection.isAutoCommit();
49             if (isNotOpen)
50             {
51                 TKDBManager.beginTransaction(); // begin transaction
52 }
53                     
54             // DELETE FROM CONTENT_VALUE WHERE CONTENT_ID = ?
55 queries[0].setQueryParams("CONTENT_ID", nodeId);
56             queries[0].execute();
57             
58             // DELETE FROM CONTENT_NODE WHERE CONTENT_ID = ?
59 queries[1].setQueryParams("CONTENT_ID", nodeId);
60             queries[1].execute();
61
62             // COMMIT TRANSACTION
63 if (isNotOpen)
64             {
65                 aTKDBConnection.commitTransaction(); // commit all changes
66 }
67         
68         }
69         catch(Throwable JavaDoc t)
70         {
71             TKDBManager.safeRollbackTransaction(t);
72         }
73         return hasResults();
74     }
75
76     public void initQuery(Connection con) {
77         super.initQuery(
78             con,
79             IS_PREPARED,
80             PARAM_ORDER,
81             PARAM_TYPES,
82             SET_RELEVANTS,
83             SQL_STRING );
84     }
85 }
86
87
88
Popular Tags