package net.sourceforge.phpeclipse.wiki.sql;
-import java.io.BufferedReader;
-import java.io.FileNotFoundException;
-import java.io.FileReader;
-import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import java.util.List;
-import net.sourceforge.phpeclipse.wiki.editor.LineTokenizer;
import net.sourceforge.phpeclipse.wiki.editor.WikiEditorPlugin;
import net.sourceforge.phpeclipse.wiki.internal.ConfigurationManager;
import net.sourceforge.phpeclipse.wiki.internal.IConfiguration;
+import net.sourceforge.phpeclipse.wiki.preferences.Util;
public class WikipediaDB {
return list;
}
+ public static String getFirstRow(ResultSet rs) throws SQLException {
+ // the order of the rows in a cursor
+ // are implementation dependent unless you use the SQL ORDER statement
+ ResultSetMetaData meta = rs.getMetaData();
+ int colmax = meta.getColumnCount();
+ int i;
+ Object o = null;
+
+ // the result set is a cursor into the data. You can only
+ // point to one row at a time
+ // assume we are pointing to BEFORE the first row
+ // rs.next() points to next row and returns true
+ // or false if there is no next row, which breaks the loop
+ for (; rs.next();) {
+ for (i = 0; i < colmax; ++i) {
+ o = rs.getObject(i + 1); // Is SQL the first column is indexed
+ // with 1 not 0
+ return o.toString();
+ }
+ }
+ return null;
+ }
+
public static void main(String[] args) {
WikipediaDB db = null;
try {
// do a query
- ArrayList list = db.queryPrefix("Programming:PHP");
+ ArrayList list = db.queryPrefixTexts("Programming:PHP");
// db.query("SELECT * FROM cur WHERE cur_title like 'Programming:PHP%'"); // WHERE num_col < 250");
for (int i = 0; i < list.size(); i++) {
System.out.println(list.get(i).toString());
// }
// }
- Connection conn;
+ private final Connection conn;
+
+ private final PreparedStatement fGetPrefixTitles;
- PreparedStatement fGetPrefixTitles;
+ private final PreparedStatement fGetPrefixTexts;
+
+ private final PreparedStatement fGetExactText;
public WikipediaDB() throws Exception // note more general exception
{
// mysql-connector.jar should be in the class path or made part of the current jar
Class.forName("com.mysql.jdbc.Driver");
- // determine the foirst SQL configuration
- List allConfigsList = ConfigurationManager.getInstance().getConfigurations();
- ArrayList configsList = new ArrayList();
+ // determine the first SQL configuration
IConfiguration configuration = null;
- for (int i = 0; i < allConfigsList.size(); i++) {
- configuration = (IConfiguration) allConfigsList.get(i);
- if (configuration.getType().equals(WikiEditorPlugin.WIKIPEDIA_SQL)) {
- break;
+ try {
+ List allConfigsList = ConfigurationManager.getInstance().getConfigurations();
+ ArrayList configsList = new ArrayList();
+ for (int i = 0; i < allConfigsList.size(); i++) {
+ configuration = (IConfiguration) allConfigsList.get(i);
+ if (configuration.getType().equals(WikiEditorPlugin.WIKIPEDIA_SQL)) {
+ break;
+ }
+ configuration = null;
}
- configuration = null;
+ } catch (Throwable th) {
+ //
}
// connect to the database. This will load the db files and start the
""); // password
}
fGetPrefixTitles = conn.prepareStatement("SELECT cur_title FROM cur WHERE LOWER( cur_title ) like ?");
+ fGetPrefixTexts = conn.prepareStatement("SELECT cur_text FROM cur WHERE LOWER( cur_title ) like ?");
+ fGetExactText = conn.prepareStatement("SELECT cur_text FROM cur WHERE cur_title = ?");
}
//use for SQL commands CREATE and SELECT
// completely examined.
}
- public synchronized ArrayList queryPrefix(String prefix) throws SQLException {
+ public synchronized ArrayList queryPrefixTitle(String prefix) throws SQLException {
fGetPrefixTitles.setString(1, prefix.toLowerCase() + '%');
ResultSet rs = null;
rs = fGetPrefixTitles.executeQuery(); // run the query
// do something with the result set.
+ ArrayList list = getResultAsString(rs);
+ if (list != null) {
+ // convert to editor format
+ for (int i = 0; i < list.size(); i++) {
+ list.set(i, Util.db2TitleLink((String) list.get(i)));
+ }
+ }
+ return list;
+ // st.close(); // NOTE!! if you close a statement the associated ResultSet is
+ }
+
+ public synchronized ArrayList queryPrefixTexts(String prefix) throws SQLException {
+ fGetPrefixTexts.setString(1, prefix.toLowerCase() + '%');
+ ResultSet rs = null;
+ rs = fGetPrefixTexts.executeQuery(); // run the query
+ // do something with the result set.
return getResultAsString(rs);
// st.close(); // NOTE!! if you close a statement the associated ResultSet is
}
+ public synchronized String queryExactText(String prefix) throws SQLException {
+ fGetExactText.setString(1, prefix);
+ ResultSet rs = null;
+ rs = fGetExactText.executeQuery(); // run the query
+ // do something with the result set.
+ return getFirstRow(rs);
+ // st.close(); // NOTE!! if you close a statement the associated ResultSet is
+ }
+
+ public static String getExactText(String prefix) {
+ WikipediaDB db = null;
+
+ try {
+ db = new WikipediaDB();
+ } catch (Exception ex1) {
+ ex1.printStackTrace(); // could not start db
+ return null; // bye bye
+ }
+
+ try {
+ String text = db.queryExactText(prefix);
+ db.shutdown();
+ return text;
+ } catch (SQLException ex3) {
+ ex3.printStackTrace();
+ }
+ return null;
+ }
+
public void shutdown() throws SQLException {
conn.close(); // if there are no other open connection
git://secure.phpeclipse.com / phpeclipse.git / blobdiff