commondao.java

雷霆论坛是用J2EE技术开发的功能强大、扩展性强、易于定制

package lightningboard.dao.hsqldb;

import java.util.Map;
import java.util.HashMap;
import java.sql.ResultSet;
import java.sql.SQLException;
import lightningboard.db.DBAccess;
import lightningboard.ActionException;
public  class CommonDAO {

  public synchronized  int getTopicID(DBAccess dba) throws SQLException {
    int i=0;
    dba.runSql("UPDATE lb_id SET i_number=i_number+1 WHERE i_id=1");
    ResultSet rs=dba.openSelect("select i_number From lb_id where i_id=1");
    if (rs.next()){
      i=rs.getInt(1);
    }
    rs.close();
    dba.closeSelect();
    return i;
  }
  public synchronized int getMessageID(DBAccess dba) throws SQLException {
    int i=0;
    dba.runSql("UPDATE lb_id SET i_number=i_number+1 WHERE i_id=2");
    ResultSet rs=dba.openSelect("select i_number From lb_id where i_id=2");
    if (rs.next()){
      i=rs.getInt(1);
    }
    rs.close();
    dba.closeSelect();
    return i;
  }

  public synchronized int getUserID(DBAccess dba) throws SQLException {
    int i=0;
    dba.runSql("UPDATE lb_id SET i_number=i_number+1 WHERE i_id=3");
    ResultSet rs=dba.openSelect("select i_number From lb_id where i_id=3");
    if (rs.next()){
      i=rs.getInt(1);
    }
    rs.close();
    dba.closeSelect();
    return i;
  }
  public Map getForumMap(DBAccess dba) throws SQLException {
    ResultSet rs=dba.openSelect("SELECT f_id,f_name FROM lb_forum ORDER BY f_order");
    Map forums=new HashMap();
    while(rs.next()){
      forums.put(rs.getString("f_id"),rs.getString("f_name"));

    }
    rs.close();
    dba.closeSelect();
     return forums;
  }
}