KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > mvnforum > util > DBUtils


1 package org.mvnforum.util;
2
3 import java.io.File JavaDoc;
4 import java.io.FileInputStream JavaDoc;
5 import java.io.FileNotFoundException JavaDoc;
6 import java.io.FileOutputStream JavaDoc;
7 import java.io.IOException JavaDoc;
8 import java.sql.Connection JavaDoc;
9 import java.sql.DriverManager JavaDoc;
10 import java.sql.ResultSet JavaDoc;
11 import java.sql.SQLException JavaDoc;
12 import java.sql.Statement JavaDoc;
13
14 import javax.xml.parsers.DocumentBuilder JavaDoc;
15 import javax.xml.parsers.DocumentBuilderFactory JavaDoc;
16 import javax.xml.parsers.ParserConfigurationException JavaDoc;
17 import javax.xml.transform.Result JavaDoc;
18 import javax.xml.transform.Source JavaDoc;
19 import javax.xml.transform.Transformer JavaDoc;
20 import javax.xml.transform.TransformerConfigurationException JavaDoc;
21 import javax.xml.transform.TransformerException JavaDoc;
22 import javax.xml.transform.TransformerFactory JavaDoc;
23 import javax.xml.transform.dom.DOMSource JavaDoc;
24 import javax.xml.transform.stream.StreamResult JavaDoc;
25
26 import org.w3c.dom.Document JavaDoc;
27
28 public class DBUtils {
29     
30     private static Document JavaDoc doc = null;
31     static {
32         try {
33             DocumentBuilder JavaDoc builder = DocumentBuilderFactory.newInstance().newDocumentBuilder();
34             doc = builder.newDocument();
35             doc.appendChild(doc.createElement("MvnForum"));
36         } catch (ParserConfigurationException JavaDoc e) {
37             e.printStackTrace();
38         }
39     }
40
41     /**
42      * Get a connection from the connection pool. The returned connection
43      * must be closed by calling DBUtils.closeConnection()
44      * @return : a new connection from the pool if succeed
45      * @throws SQLException : if cannot get a connection from the pool
46      * @throws IOException
47      * @throws FileNotFoundException
48      */

49     public static Connection JavaDoc getPhpbbConnection()
50         throws SQLException JavaDoc {
51
52         Connection JavaDoc conection = null;
53         String JavaDoc phpurl = "jdbc:mysql://" + Phpbb2MvnforumConfig.PHP_HOST + "/" + Phpbb2MvnforumConfig.PHP_DB;
54
55         try {
56             Class.forName("com.mysql.jdbc.Driver").newInstance();
57         } catch (Exception JavaDoc E) {
58             System.err.println("Unable to load driver.");
59             E.printStackTrace();
60         }
61
62         conection = DriverManager.getConnection(phpurl, Phpbb2MvnforumConfig.PHP_USER, Phpbb2MvnforumConfig.PHP_PASS);
63
64         return conection;
65     }
66
67     /**
68      * Get a connection from the connection pool. The returned connection
69      * must be closed by calling DBUtils.closeConnection()
70      * @return : a new connection from the pool if succeed
71      * @throws SQLException : if cannot get a connection from the pool
72      * @throws IOException
73      * @throws FileNotFoundException
74      */

75
76     public static Connection JavaDoc getMvnConnection()
77         throws SQLException JavaDoc {
78
79         Connection JavaDoc conection = null;
80         String JavaDoc phpurl = "jdbc:mysql://" + Phpbb2MvnforumConfig.MVN_HOST + "/" + Phpbb2MvnforumConfig.MVN_DB;
81
82         try {
83             Class.forName("com.mysql.jdbc.Driver").newInstance();
84         } catch (Exception JavaDoc E) {
85             System.err.println("Unable to load driver.");
86             E.printStackTrace();
87         }
88
89         conection = DriverManager.getConnection(phpurl, Phpbb2MvnforumConfig.MVN_USER, Phpbb2MvnforumConfig.MVN_PASS);
90
91         return conection;
92     }
93
94     /**
95      * Use this method to close the ResultSet
96      * @param rs : the resultset that needs to be closed
97      */

98     public static void closeResultSet(ResultSet JavaDoc rs) {
99         try {
100             if (rs != null)
101                 rs.close();
102         } catch (SQLException JavaDoc e) {
103             e.printStackTrace();
104         }
105     }
106
107     /**
108      * Use this method to close the Statement
109      * @param statement : the statement that needs to be closed
110      */

111     public static void closeStatement(Statement JavaDoc statement) {
112         try {
113             if (statement != null)
114                 statement.close();
115         } catch (SQLException JavaDoc e) {
116             e.printStackTrace();
117         }
118     }
119
120     /**
121      * Use this method to return the connection to the connection pool
122      * Do not use this method to close connection that is not from
123      * the connection pool
124      * @param connection : the connection that needs to be returned to the pool
125      */

126     public static void closeConnection(Connection JavaDoc connection) {
127         if (connection == null)
128             return;
129         try {
130             connection.close();
131         } catch (SQLException JavaDoc e) {
132             e.printStackTrace();
133         }
134     }
135     
136     public static Document JavaDoc getDomDocument(){
137         return doc;
138     }
139     
140     public static void writeXmlFile(Document JavaDoc doc, String JavaDoc filename) {
141         try {
142             // Prepare the DOM document for writing
143
Source JavaDoc source = new DOMSource JavaDoc(doc);
144     
145             // Prepare the output file
146
File JavaDoc file = new File JavaDoc(filename);
147             Result JavaDoc result = new StreamResult JavaDoc(file);
148     
149             // Write the DOM document to the file
150
Transformer JavaDoc xformer = TransformerFactory.newInstance().newTransformer();
151             xformer.transform(source, result);
152         } catch (TransformerConfigurationException JavaDoc e) {
153             e.printStackTrace();
154         } catch (TransformerException JavaDoc e) {
155             e.printStackTrace();
156         }
157     }
158     
159     public static FileInputStream JavaDoc getInput() {
160         try {
161             FileInputStream JavaDoc file = new FileInputStream JavaDoc(Phpbb2MvnforumConfig.EXPORT_XML);
162             return file;
163         } catch (FileNotFoundException JavaDoc e) {
164             // TODO Auto-generated catch block
165
e.printStackTrace();
166         }
167         return null;
168     }
169
170     public static FileOutputStream JavaDoc getOutput() {
171         // TODO Auto-generated method stub
172
FileOutputStream JavaDoc file;
173         try {
174             file = new FileOutputStream JavaDoc(Phpbb2MvnforumConfig.EXPORT_XML);
175             return file;
176         } catch (FileNotFoundException JavaDoc e) {
177             // TODO Auto-generated catch block
178
e.printStackTrace();
179         }
180         return null;
181         
182     }
183
184 }
185
Popular Tags