Project

General

Profile

1 15 jones
/**
2
 *        Name: DBSAXElement.java
3
 *     Purpose: A Class that represents an XML element and its contents
4 35 jones
 *   Copyright: 2000 Regents of the University of California and the
5
 *              National Center for Ecological Analysis and Synthesis
6 15 jones
 *     Authors: Matt Jones
7
 *
8
 *     Version: '$Id$'
9
 */
10
11 74 jones
package edu.ucsb.nceas.metacat;
12 15 jones
13
import java.sql.*;
14
import java.io.IOException;
15
import java.util.Hashtable;
16
import java.util.Enumeration;
17
18 31 jones
/**
19
 * A Class that represents an XML element and its contents and
20
 * can write its own representation to a database connection
21
 */
22 21 jones
public class DBSAXElement extends BasicElement {
23 15 jones
24 16 jones
    private Connection		conn;
25 15 jones
26 31 jones
    /**
27
     * Construct a new element instance
28
     *
29
     * @param conn the JDBC Connection to which all information is written
30
     * @param tagname the name of the element
31
     * @param parent_id the parent id number for this element
32
     */
33 18 jones
    public DBSAXElement (Connection conn, String tagname,
34 72 bojilova
                         long parent_id, int nodeIndex) {
35 21 jones
36 72 bojilova
      super(tagname, parent_id, nodeIndex);
37 21 jones
38 16 jones
      this.conn = conn;
39
      writeElementToDB();
40 22 jones
    }
41 15 jones
42 19 jones
    /** creates SQL code and inserts new element into DB connection */
43
    private void writeElementToDB() {
44
        try {
45
          conn.setAutoCommit(false);
46
          PreparedStatement pstmt;
47 29 jones
          if (getParentID() != 0) {
48 19 jones
            pstmt = conn.prepareStatement(
49 20 jones
                "INSERT INTO xml_nodes (nodeid, nodetype, " +
50 72 bojilova
                "nodename, parentnodeid, nodeindex) VALUES (null, ?, ?, ?, ?)");
51 19 jones
          } else {
52
            pstmt = conn.prepareStatement(
53 20 jones
                "INSERT INTO xml_nodes (nodeid, nodetype, nodename) " +
54
                "VALUES (null, ?, ?)");
55 19 jones
          }
56
57
          // Bind the values to the query
58 20 jones
          pstmt.setString(1, "ELEMENT");
59
          pstmt.setString(2, getTagName());
60 72 bojilova
          //pstmt.setInt(4, null);
61 29 jones
          if (getParentID() != 0) {
62
            pstmt.setLong(3, getParentID());
63 72 bojilova
            pstmt.setInt(4, getNodeIndex());
64 19 jones
          }
65
          // Do the insertion
66
          pstmt.execute();
67
          pstmt.close();
68 29 jones
          setElementID(getAssignedElementID());
69 19 jones
          conn.commit();
70
          conn.setAutoCommit(true);
71
        } catch (SQLException e) {
72
          System.out.println(e.getMessage());
73
        }
74
    }
75
76 72 bojilova
    /** creates SQL code and inserts comment into DB connection */
77 92 bojilova
    void writeCommentToDB(String data, int nodeIndex) {
78 72 bojilova
        try {
79
          PreparedStatement pstmt;
80
          pstmt = conn.prepareStatement(
81
                "INSERT INTO xml_nodes (nodeid, nodetype, " +
82 92 bojilova
                "nodename, parentnodeid, nodedata, nodeindex) VALUES (null, ?, null, ?, ?, ?)");
83 72 bojilova
84
          // Bind the values to the query
85
          pstmt.setString(1, "COMMENT");
86
          pstmt.setLong(2, getElementID());
87
          pstmt.setString(3, data);
88 92 bojilova
          pstmt.setInt(4, nodeIndex);
89 72 bojilova
          // Do the insertion
90
          pstmt.execute();
91
          pstmt.close();
92
        } catch (SQLException e) {
93
          System.out.println(e.getMessage());
94
        }
95
    }
96
97 19 jones
    /** look up the assigned element id from DB connection */
98
    private long getAssignedElementID() {
99
        long assigned_id=0;
100 16 jones
        Statement stmt;
101
        try {
102
          stmt = conn.createStatement();
103 20 jones
          stmt.execute("SELECT xml_nodes_id_seq.currval FROM dual");
104 16 jones
          try {
105
            ResultSet rs = stmt.getResultSet();
106
            try {
107
              boolean tableHasRows = rs.next();
108
              if (tableHasRows) {
109
                try {
110 19 jones
                  assigned_id = rs.getLong(1);
111 16 jones
                } catch (SQLException e) {
112
                  System.out.println("Error with getInt: " + e.getMessage());
113
                }
114
              }
115
            } catch (SQLException e) {
116
              System.out.println("Error with next: " + e.getMessage());
117
            }
118
          } catch (SQLException e) {
119
            System.out.println("Error with getrset: " + e.getMessage());
120
          }
121
          stmt.close();
122
        } catch (SQLException e) {
123
          System.out.println("Error getting id: " + e.getMessage());
124
        }
125
126 19 jones
        // assign the new ID number
127
        return assigned_id;
128 16 jones
    }
129
130 15 jones
    /** Add a new attribute to this element, or set its value */
131
    public void setAttribute(String attName, String attValue) {
132
      if (attName != null) {
133 19 jones
        // Enter the attribute in the hash table
134 29 jones
        super.setAttribute(attName, attValue);
135 19 jones
136
        // And enter the attribute in the database
137
        try {
138
          PreparedStatement pstmt = conn.prepareStatement(
139 20 jones
              "INSERT INTO xml_nodes (nodeid, nodetype, " +
140
              "nodename, nodedata, parentnodeid) VALUES (null, ?, ?, ?, ?)");
141 19 jones
142
          // Bind the values to the query
143 20 jones
          pstmt.setString(1, "ATTRIBUTE");
144 19 jones
          pstmt.setString(2, attName);
145
          pstmt.setString(3, attValue);
146 20 jones
          pstmt.setLong(4, getElementID());
147 19 jones
148
          // Do the insertion
149
          pstmt.execute();
150
          pstmt.close();
151
        } catch (SQLException e) {
152
          System.out.println(e.getMessage());
153
        }
154
155 15 jones
      } else {
156
        System.err.println("Attribute name must not be null!");
157
      }
158
    }
159
160 18 jones
    /** Write the element content to the db connection */
161
    public void writeContentToDB() {
162
        try {
163
          PreparedStatement pstmt = conn.prepareStatement(
164 20 jones
                "UPDATE xml_nodes SET nodedata = ? WHERE nodeid = ?");
165 18 jones
166
          // Bind the values to the query
167 29 jones
          pstmt.setString(1, getContent());
168
          pstmt.setLong(2, getElementID());
169 18 jones
170
          // Do the update
171
          pstmt.execute();
172
          pstmt.close();
173
174
        } catch (SQLException e) {
175
          System.out.println(e.getMessage());
176
        }
177
    }
178 15 jones
}