plog4u-devel

[Axel C. K. <ax...@us...>]

Update of /cvsroot/plog4u/net.sourceforge.phpeclipse.wiki/src/net/sourceforge/phpeclipse/wiki/actions/sql
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv1231/src/net/sourceforge/phpeclipse/wiki/actions/sql

Modified Files:
	DownloadSQLJob.java UploadSQLJob.java 
Added Files:
	CurRow.java 
Log Message:
Using new Wikipedia API library: bliki.jar

Index: DownloadSQLJob.java
===================================================================
RCS file: /cvsroot/plog4u/net.sourceforge.phpeclipse.wiki/src/net/sourceforge/phpeclipse/wiki/actions/sql/DownloadSQLJob.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -C2 -d -r1.4 -r1.5
*** DownloadSQLJob.java	27 Jun 2005 20:18:31 -0000	1.4
--- DownloadSQLJob.java	20 Sep 2006 21:26:59 -0000	1.5
***************
*** 29,33 ****
  import org.eclipse.core.runtime.jobs.Job;
  import org.eclipse.ui.progress.IProgressConstants;
- import org.jzonic.yawiki.wikipedia.sql.CurRow;
  
  public class DownloadSQLJob extends WorkspaceJob {
--- 29,32 ----

--- NEW FILE: CurRow.java ---
package net.sourceforge.phpeclipse.wiki.actions.sql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.Date;

public class CurRow {

  public static String getCurrentTimestamp() {
    Timestamp t = new Timestamp((new Date()).getTime());
    String timeStr = t.toString();
    StringBuffer buf = new StringBuffer(14);
    buf.append(timeStr.charAt(0));
    buf.append(timeStr.charAt(1));
    buf.append(timeStr.charAt(2));
    buf.append(timeStr.charAt(3));
    buf.append(timeStr.charAt(5));
    buf.append(timeStr.charAt(6));
    buf.append(timeStr.charAt(8));
    buf.append(timeStr.charAt(9));
    buf.append(timeStr.charAt(11));
    buf.append(timeStr.charAt(12));
    buf.append(timeStr.charAt(14));
    buf.append(timeStr.charAt(15));
    buf.append(timeStr.charAt(17));
    buf.append(timeStr.charAt(18));
    return buf.toString();
  }

  public static void main(String[] args) {
    try {
      //  Load the Database Engine JDBC driver
      // mysql-connector.jar should be in the class path or made part of the current jar
      Class.forName("com.mysql.jdbc.Driver");

      // default test configuration for XAMPP distribution
      Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/wikidb", // filenames
          "root", // category
          ""); // password
      CurRow tab = new CurRow(conn);
      String title = "Wiki_Science:Self_Healing";
      Timestamp t = new Timestamp((new Date()).getTime());
      String timeStr = getCurrentTimestamp();

      tab.selectCurRow(title);
      tab.dump();
      tab.updateCurRow(tab.fCur_text, timeStr);

      tab.selectCurRow(title);
      tab.dump();

    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  private final Connection fConnection;

  //  CREATE TABLE `cur` (
  //      `cur_id` int(8) unsigned NOT NULL auto_increment,
  //      `cur_namespace` tinyint(2) unsigned NOT NULL default '0',
  //      `cur_title` varchar(255) binary NOT NULL default '',
  //      `cur_text` mediumtext NOT NULL,
  //      `cur_comment` tinyblob NOT NULL,
  //      `cur_user` int(5) unsigned NOT NULL default '0',
  //      `cur_user_text` varchar(255) binary NOT NULL default '',
  //      `cur_timestamp` varchar(14) binary NOT NULL default '',
  //      `cur_restrictions` tinyblob NOT NULL,
  //      `cur_counter` bigint(20) unsigned NOT NULL default '0',
  //      `cur_is_redirect` tinyint(1) unsigned NOT NULL default '0',
  //      `cur_minor_edit` tinyint(1) unsigned NOT NULL default '0',
  //      `cur_is_new` tinyint(1) unsigned NOT NULL default '0',
  //      `cur_random` double unsigned NOT NULL default '0',
  //      `cur_touched` varchar(14) binary NOT NULL default '',
  //      `inverse_timestamp` varchar(14) binary NOT NULL default '',
  //      UNIQUE KEY `cur_id` (`cur_id`),
  //      KEY `cur_namespace` (`cur_namespace`),
  //      KEY `cur_title` (`cur_title`(20)),
  //      KEY `cur_timestamp` (`cur_timestamp`),
  //      KEY `cur_random` (`cur_random`),
  //      KEY `name_title_timestamp` (`cur_namespace`,`cur_title`,`inverse_timestamp`),
  //      KEY `user_timestamp` (`cur_user`,`inverse_timestamp`),
  //      KEY `usertext_timestamp` (`cur_user_text`,`inverse_timestamp`),
  //      KEY `namespace_redirect_timestamp` (`cur_namespace`,`cur_is_redirect`,`cur_timestamp`)
  //    )
  private long fCur_id;

  private String fCur_namespace;

  private String fCur_text;

  private String fCur_timestamp;

  private String fCur_title;

  private PreparedStatement fSelectTitle;

  private PreparedStatement fUpdateTitle;

  public CurRow(Connection con) throws SQLException {
    fConnection = con;
  }

  public void dump() {
    System.out.println(fCur_id);
    System.out.println(fCur_namespace);
    System.out.println(fCur_title);
    System.out.println(fCur_text);
    System.out.println(fCur_timestamp);
  }

  /**
   * @return Returns the cur_text.
   */
  public String getCur_text() {
    return fCur_text;
  }

  /**
   * @return Returns the cur_timestamp.
   */
  public String getCur_timestamp() {
    return fCur_timestamp;
  }

  /**
   * @return Returns the cur_title.
   */
  public String getCur_title() {
    return fCur_title;
  }

  /**
   * @return Returns the selectTitle.
   */
  public PreparedStatement getSelectTitle() {
    return fSelectTitle;
  }

  /**
   * @return Returns the updateTitle.
   */
  public PreparedStatement getUpdateTitle() {
    return fUpdateTitle;
  }

  public void init() {
    fCur_id = 0;
    fCur_namespace = "";
    fCur_title = "";
    fCur_text = "";
    fCur_timestamp = "";
  }
 
  private void initPrepTitle() throws SQLException {
    fSelectTitle = fConnection
        .prepareStatement("SELECT cur_id, cur_namespace, cur_text, cur_timestamp FROM cur WHERE cur_title = ?");
  }

  private void initUpdateTitle() throws SQLException {
    fUpdateTitle = fConnection.prepareStatement("UPDATE cur SET cur_text = ?, cur_timestamp = ? WHERE cur_id = ?");
  }

  public boolean selectCurRow(String title) throws SQLException {
    if (fSelectTitle == null) {
      initPrepTitle();
    }
    init();
    fSelectTitle.setString(1, title);
    ResultSet res = fSelectTitle.executeQuery();
    if (res.next()) {
      fCur_id = res.getLong("cur_id");
      fCur_namespace = res.getString("cur_namespace");
      fCur_title = title;
      fCur_text = res.getString("cur_text");
      fCur_timestamp = res.getString("cur_timestamp");
      return true;
    }
    return false;
  }

  public CurRow updateCurRow(String text, String timestamp) throws SQLException {
    if (fUpdateTitle == null) {
      initUpdateTitle();
    }
    fCur_text = text;
    fCur_timestamp = timestamp;
    fUpdateTitle.setString(1, text);
    fUpdateTitle.setString(2, timestamp);
    fUpdateTitle.setLong(3, fCur_id);
    fUpdateTitle.executeUpdate();
    return this;
  }
  
}
Index: UploadSQLJob.java
===================================================================
RCS file: /cvsroot/plog4u/net.sourceforge.phpeclipse.wiki/src/net/sourceforge/phpeclipse/wiki/actions/sql/UploadSQLJob.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** UploadSQLJob.java	27 Jun 2005 20:18:33 -0000	1.3
--- UploadSQLJob.java	20 Sep 2006 21:26:59 -0000	1.4
***************
*** 32,36 ****
  import org.eclipse.core.runtime.jobs.Job;
  import org.eclipse.ui.progress.IProgressConstants;
- import org.jzonic.yawiki.wikipedia.sql.CurRow;
  
  public class UploadSQLJob extends WorkspaceJob {
--- 32,35 ----