我現在做好了bean,里邊屬性和表中列名一致,在頁面傳值給一個類后我把數據保存到了bean里邊.然后我想再寫個方法把bean做為對象傳過去.然后把數據保存到數據庫.請高手指教..我是菜鳥..謝謝關鍵點在于..在這個類中我不知道該怎么引用bean.怎么能把bean的屬性保存到數據庫.而且要同用.不管是哪個bean都能這么做..哪為高手能給寫個小例子..
3 回答
函數式編程
TA貢獻1807條經驗 獲得超9個贊
不知道怎么引用bean?
javabean也是一個普通的類啊，要是和你用來調用bean在同一包中就不用寫import語句了，直接實例化它啊，比如你的bean的名字叫UserInfo
你就在類中寫
UserInfo ui=new UserInfo();
然后就可以讀取bean里面的數據了，不要告訴我你bean沒寫規范
陪伴而非守候
TA貢獻1757條經驗 獲得超8個贊
1，先建一個bean，里面的變量，與數據庫中的列相同：
public class PCourse {
/***
* *創建課業號，課程號，專業號，以及修改中用到的舊的課業號 的存儲參數，
* 同時定義屬性
*
*
*/
private String csID;
private String courseID;
private String speciaID;
private String oldcsID;
public String getcsID(){
return csID;
}
public void setcsID(String csID){
this.csID=csID;
}
public String getcourseID() {
return courseID;
}
public void setcourseID(String courseID) {
this.courseID = courseID;
}
public String getspeciaID() {
return speciaID;
}
public void setspeciaID(String speciaID) {
this.speciaID =speciaID;
}
public String getoldcsID() {
return oldcsID;
}
public void setoldcsID(String oldcsID) {
this.oldcsID =oldcsID;
}
}
2，然后建一個DAO（Database Access Object）接口，即里面就是一些數據庫操作的方法，但先不實現他：
public interface PCourseDao {
/**定義在選課表上的插入方法
*
* @param pc
* @return
* @throws Exception
*/
public int insert(PCourse pc) throws Exception;
/**定義在選課表上的更新方法
*
* @param pc
* @return
* @throws Exception
*/
public int update(PCourse pc) throws Exception;
/**定義在選課表上的刪除方法
*
* @param pc
* @return
* @throws Exception
*/
public int delete(String csID) throws Exception;
/**定義在選課表上的按課業號的查詢方法
*
* @param pc
* @return
* @throws Exception
*/
public PCourse queryBycsID(String csID) throws Exception;
/**定義在選課表上的按課程號的查詢方法
*
* @param pc
* @return
* @throws Exception
*/
public List queryBycourseId(String courseID) throws Exception;
/**定義在選課表上的按專業號查詢方法
*
* @param spID
* @return
* @throws Exception
*/
public List queryByspID(String speciaID) throws Exception;
}
3，實現接口類：
import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import com.hb.sim.vo.Attendance;
import com.hb.sim.vo.PCourse;
import com.hb.sim.dao.PCourseDao;
import com.hb.sim.db.DbConnection;
public class PCourseDaoImpl implements PCourseDao{
public int updateLines;
public PCourse pc=null;
private DbConnection db=null;
public PCourseDaoImpl(){
db=new DbConnection();
}
public int insert(PCourse pc) throws Exception {
String sql="insert into P_COURSE (CS_ID,SPECIA_ID,COURSE_ID) values (?,?,?)";
Connection conn=db.getConnection();
PreparedStatement pstmt=null;
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,pc.getcsID());
pstmt.setString(2, pc.getspeciaID());
pstmt.setString(3, pc.getcourseID());
updateLines=pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
finally{
db.close();
}
return updateLines;
}
public int delete(String csID) throws Exception {
String sql="delete from P_COURSE where CS_ID=?";
Connection conn=db.getConnection();
PreparedStatement pstmt=null;
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,csID);
updateLines=pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}
finally{
try {
if(pstmt!=null){
pstmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
db.close();
return updateLines;
}
public int update(PCourse pc) throws Exception {
String sql="update P_COURSE set SPECIA_ID=?,COURSE_ID=? where CS_ID=?";
Connection conn=db.getConnection();
PreparedStatement pstmt=null;
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, pc.getspeciaID());
pstmt.setString(2, pc.getcourseID());
pstmt.setString(3, pc.getcsID());
updateLines=pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
finally{
try {
if(pstmt!=null){
pstmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
db.close();
return updateLines;
}
public List queryBycourseId(String courseID) throws Exception{
List l=new ArrayList();
String sql="select * from P_COURSE where COURSE_ID=?";
Connection conn=db.getConnection();
PreparedStatement pstmt=null;
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, courseID);
ResultSet rs=pstmt.executeQuery();
while(rs.next()){
PCourse pc=new PCourse();
pc.setcsID(rs.getString("CS_ID"));
pc.setcourseID(rs.getString("COURSE_ID"));
pc.setspeciaID(rs.getString("SPECIA_ID"));
l.add(pc);
}
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
finally{
try {
if(pstmt!=null){
pstmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
db.close();
return l;
}
public List queryByspID(String speciaID) {
List l=new ArrayList();
String sql="select * from P_COURSE where SPECIA_ID=?";
Connection conn=db.getConnection();
PreparedStatement pstmt=null;
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1, speciaID);
ResultSet rs=pstmt.executeQuery();
while(rs.next()){
PCourse pc=new PCourse();
pc.setcsID(rs.getString("CS_ID"));
pc.setspeciaID(rs.getString("SPECIA_ID"));
pc.setcourseID(rs.getString("COURSE_ID"));
l.add(pc);
}
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
finally{
try {
if(pstmt!=null){
pstmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
db.close();
return l;
}
public PCourse queryBycsID(String csID) throws Exception {
String sql="select * from P_COURSE where CS_ID=?";
Connection conn=db.getConnection();
PreparedStatement pstmt=null;
PCourse pc=null;
try {
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,csID);
ResultSet rs=pstmt.executeQuery();
while(rs.next()){
pc=new PCourse();
pc.setcsID(rs.getString("CS_ID"));
pc.setcourseID(rs.getString("COURSE_ID"));
pc.setspeciaID(rs.getString("SPECIA_ID"));
}
rs.close();
}catch (SQLException e) {
e.printStackTrace();
}
finally{
try {
if(pstmt!=null){
pstmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
db.close();
return pc ;
}
}
4，就是你的邏輯代碼，set你的存儲對象，然后調用相應的數據庫操作方法，就會保存到數據庫中
按你的要求，大概就是這樣，有什么疑問給我留言??！
月關寶盒
TA貢獻1772條經驗 獲得超5個贊
這個是BEAN
package cn.ccnp.area;
import java.io.Serializable;
public class Area implements Serializable {
/**
* 區域ID
*/
private String areaId;
/**
* 區域名稱
*/
private String areaName;
/**
* 所屬區縣
*/
private String areaFatherId;
/**
* 所屬省市
*/
private String areaGrandfatherId;
/**
* 區域ID getter,setter method
*/
public String getAreaId( ){
return areaId;
}
public void setAreaId( String areaId ){
this.areaId = areaId;
}
/**
* 區域名稱 getter,setter method
*/
public String getAreaName( ){
return areaName;
}
public void setAreaName( String areaName ){
this.areaName = areaName;
}
/**
* 所屬區縣 getter,setter method
*/
public String getAreaFatherId( ){
return areaFatherId;
}
public void setAreaFatherId( String areaFatherId ){
this.areaFatherId = areaFatherId;
}
/**
* 所屬省市 getter,setter method
*/
public String getAreaGrandfatherId( ){
return areaGrandfatherId;
}
public void setAreaGrandfatherId( String areaGrandfatherId ){
this.areaGrandfatherId = areaGrandfatherId;
}
}
這個是對數據庫的操作。懶得挑了。。都粘過來，你自己看吧，有些是公司內部的類，不用都明白哈~~
package cn.ccnp.area;
/**
* <p>Title: AreaMgrImpl</p>
* <p>Description: area implement</p>
* <p>Copyright: Copyright (c) 2006</p>
* <p>Company: jadosoft</p>
* @author Yangyang
* @version 1.0
*/
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import org.apache.log4j.Logger;
import cn.jado.app.log.OperatorLog;
import cn.jado.app.log.OperatorLogger;
import cn.jado.lib.QuoteReplace;
import cn.jado.lib.web.CommonDAO;
import cn.jado.lib.web.Page;
import cn.jado.lib.web.PageDiv;
public class AreaMgrImpl {
/**
* Constructor
*/
public AreaMgrImpl(){
}
/**
* OperatorLog
*/
private OperatorLog log = null;
private int rowNum = 0;
/**
* OperatorLogSetter
*/
public void setLog(Object o) {
if (o instanceof OperatorLog) {
OperatorLog log = (OperatorLog) o;
this.log = log;
}
}
/**
* DataSource lookup jndi
*/
private String jndi = "jdbc/ccn";
private String tableName = "area";
/**
* log4j
*/
private static Logger logger= Logger.getLogger(AreaMgrImpl.class.getName());
/**
* 判斷是否已經存在相同記錄
* @param area 記錄的值對象
* @return 是否存在另一記錄與該記錄相同
*/
public boolean existedArea( Area area ) {
//單引號替換
area = (Area)QuoteReplace.replace(area);
StringBuffer sqlBuf = new StringBuffer(100);
sqlBuf.append(" select count(*) from " + tableName);
/* @toDo： 要保留的行，去掉行前注釋符，注：只保留主鍵（或聯合主鍵的行)做是否存在的判斷依據 */
sqlBuf.append(" where area_id = " + area.getAreaId()); //區域ID
// sqlBuf.append(" and area_name = '" + area.getAreaName()+ "'"); //區域名稱
// sqlBuf.append(" and area_father_id = '" + area.getAreaFatherId()+ "'"); //所屬區縣
// sqlBuf.append(" and area_grandfather_id = '" + area.getAreaGrandfatherId()+ "'"); //所屬省市
logger.warn("---sql:existedArea---" + sqlBuf);
CommonDAO dao = null;
ResultSet rs = null;
boolean existed = false;
try {
dao = new CommonDAO(jndi);
rs = dao.query(sqlBuf.toString());
if ( rs.next() ){
if (rs.getInt(1) != 0) {
existed = true;
}
}
}
catch (Exception e) {
e.printStackTrace();
}
finally {
dao.destroy();
}
return existed;
}
/**
* add a new record
* @param area 新增記錄的值對象
* @return 是否添加成功
*/
public boolean addArea( Area area ){
//組合sql語句
StringBuffer sqlBuf = new StringBuffer(100);
sqlBuf
.append("insert into "+tableName)
.append("(")
.append("area_id") //區域ID
.append(",area_name") //區域名稱
.append(",area_father_id") //所屬區縣
.append(",area_grandfather_id") //所屬省市
.append(")")
.append(" values(");
StringBuffer sqlBufValues = new StringBuffer(100);
sqlBufValues
.append("" + area.getAreaId()) //區域ID
.append(",'" + area.getAreaName() + "'") //區域名稱
.append(",'" + area.getAreaFatherId() + "'") //所屬區縣
.append(",'" + area.getAreaGrandfatherId() + "'") //所屬省市
.append(")");
sqlBuf = sqlBuf.append(sqlBufValues);
logger.warn("---sql:addArea---"+sqlBuf);
//更新數據
return this.updateData( sqlBuf.toString(),"addArea" );
}
/**
* edit the specified object
* @param area 修改成的新記錄的對象
* @return 修改是否成功
*/
public boolean editArea( Area area){
//組合sql語句
StringBuffer sqlBuf = new StringBuffer(100);
sqlBuf
.append("update "+tableName+" set ")
.append("area_id = " + area.getAreaId()) //區域ID
.append(",area_name = '" + area.getAreaName() + "'") //區域名稱
.append(",area_father_id = '" + area.getAreaFatherId() + "'") //所屬區縣
.append(",area_grandfather_id = '" + area.getAreaGrandfatherId() + "'") //所屬省市
.append(" where area_id = ")
.append(area.getAreaId());
logger.warn("---sql:editArea---"+sqlBuf);
//更新數據
return updateData( sqlBuf.toString(),"editArea" );
}
/**
* delete the specified object by id
* @param areaID 記錄的ID值
* @return 刪除記錄是否成功
*/
private boolean delAreaById(String areaID) {
StringBuffer sqlBuf = new StringBuffer(100);
sqlBuf.append(" delete from "+tableName);
sqlBuf.append(" where area_id=");
sqlBuf.append(areaID);
logger.warn("---sql:delAreaById---"+sqlBuf);
boolean result = this.updateData( sqlBuf.toString(), "delAreaById" );
return result;
}
/**
* delete the specified objects
* @param areaIDs 多條記錄ID組成的數組
* @return boolean 刪除多條是否成功
*/
public boolean delAreas(String[] areaIDs) {
if ( areaIDs != null && areaIDs.length > 0 ) {
int size = areaIDs.length;
for (int i = 0; i < size; i++) {
if ( !this.delAreaById( areaIDs[i]) ) {
return false;
}
}
return true;
}
return false;
}
/**
* get the specified object
* @param areaId 記錄的ID值
* @return 與該ID匹配的記錄的值對象
*/
public Area getAreaByID( String areaId ){
Area area = null;
//組合查詢條件
StringBuffer sqlBuf = new StringBuffer();
sqlBuf
.append("select * from "+tableName+" where area_id = ")
.append(areaId);
logger.warn("---sql:getAreaByID---"+sqlBuf);
CommonDAO dao = null;
ResultSet rs = null;
try{
dao = new CommonDAO(jndi);
rs = dao.query(sqlBuf.toString());
//讀取結果集信息
if ( rs.next() ){
area = this.readDataFromRs(rs);
}
}catch( Exception ex ){
ex.printStackTrace();
}finally{
dao.destroy();
dao=null;
sqlBuf = null;
}
return area;
}
/**
* get all objects
* @param
* @return 全部記錄的列表
*/
public ArrayList getAreaList(){
ArrayList arr = null;
//組合查詢條件
String sql = "select * from "+tableName+" order by area_id desc";
logger.warn("---sql:getAreaList---"+sql);
CommonDAO dao = null;
ResultSet rs = null;
try{
dao = new CommonDAO(jndi);
rs = dao.query(sql);
//讀取結果集信息
arr = this.readDataListFromRs(rs);
}catch( Exception ex ){
ex.printStackTrace();
}finally{
dao.destroy();
dao=null;
sql = null;
}
return arr;
}
/**
* get all objects
* @param area
* @return 滿足查詢條件的記錄的對象組成的列表
*/
public ArrayList getAreaList(Area area ){
ArrayList arr = null;
//組合查詢條件
StringBuffer sqlBuf = new StringBuffer(50);
sqlBuf.append( "select * from "+tableName);
sqlBuf.append( " where 1=1 ");
/* @todo: 可以在這里加上你自己的查詢條件 */
sqlBuf.append( " order by area_id desc");
logger.warn("---sql:getAreaList---"+sqlBuf);
CommonDAO dao = null;
ResultSet rs = null;
try{
dao = new CommonDAO(jndi);
rs = dao.query(sqlBuf.toString());
//讀取結果集信息
arr = this.readDataListFromRs(rs);
}catch( Exception ex ){
ex.printStackTrace();
}finally{
dao.destroy();
dao=null;
sqlBuf = null;
}
return arr;
}
/**
* get all objects by search
* 數值、日期等按指定區間查詢
* @param areaSearch 查詢條件的值對象
* @return 滿足條件的記錄組成的對象列表
*/
public ArrayList getAreaListBySearch(AreaSearch areaSearch ){
ArrayList arr = null;
StringBuffer sqlBuf = new StringBuffer(50);
StringBuffer sqlWhere = this.getSqlwherBySearch(areaSearch);
sqlBuf.append( "select * from " + tableName + " where 1=1 ");
sqlBuf.append(sqlWhere);
sqlBuf.append( " order by area_id desc");
logger.warn("---sql:getAreaListSplit---"+sqlBuf);
CommonDAO dao = null;
ResultSet rs = null;
try{
dao = new CommonDAO(jndi);
rs = dao.query(sqlBuf.toString());
//讀取結果集信息
arr = this.readDataListFromRs(rs);
}catch( Exception ex ){
ex.printStackTrace();
}finally{
dao.destroy();
dao=null;
sqlBuf = null;
}
return arr;
}
/**
* 查詢結果分頁顯示
* @param pageBean 頁信息的對象
* @return 是否分頁查詢成功
*/
public boolean getAreaListSplit( Page pageBean ){
ArrayList arr = new ArrayList();
int pageSize = 0;
int pageNo = 0;
if (pageBean == null) {
return false;
}
if (pageBean.getPageSize() <= 0) {
pageBean.setPageSize(50);
}
if (pageBean.getPageNo()<= 0) {
pageBean.setPageNo(1);
}
pageSize = pageBean.getPageSize();
pageNo = pageBean.getPageNo();
StringBuffer sql = new StringBuffer(" select * from "+tableName+" order by area_id desc");
StringBuffer countSql = new StringBuffer("select count(*) from "+tableName);
logger.warn("---sql:getAreaListSplit---"+sql);
logger.warn("---countSql:getAreaListSplit---"+countSql);
CommonDAO dao = null;
try{
dao = new CommonDAO(jndi);
rowNum = PageDiv.getCount(countSql.toString(), dao);
pageBean.setPageInfo(rowNum, pageSize);
//執行查找
ResultSet rs = PageDiv.getResultSet(pageNo, pageSize, rowNum, sql.toString(), dao);
for (int i = 0; i < pageSize && rs.next(); i++) {
//從結果集中讀取數據
arr.add(readDataFromRs(rs));
}
}catch( Exception ex ){
ex.printStackTrace();
}finally{
dao.destroy();
}
pageBean.setList(arr);
return true;
}
/**
* get objects by search ,display split
* 按值查詢并分頁顯示，數值、日期等查指定區間
* @param pageBean 頁信息對象
* @param areaSearch 查詢條件對象
* @return 獲得頁列表是否成功
*/
public boolean getAreaListSplitBySearch( Page pageBean,AreaSearch areaSearch ){
ArrayList arr = new ArrayList();
int pageSize = 0;
int pageNo = 0;
if (pageBean == null) {
return false;
}
if (pageBean.getPageSize() <= 0) {
pageBean.setPageSize(15);
}
if (pageBean.getPageNo()<= 0) {
pageBean.setPageNo(1);
}
pageSize = pageBean.getPageSize();
pageNo = pageBean.getPageNo();
StringBuffer sqlWhere = this.getSqlwherBySearch(areaSearch);
StringBuffer sql = new StringBuffer(" select * from " + tableName + " where 1=1 " + sqlWhere + " order by area_id desc");
StringBuffer countSql = new StringBuffer("select count(*) from " + tableName + " where 1=1 " + sqlWhere);
logger.warn("---sql:getAreaListSplit---"+sql);
logger.warn("---countSql:getAreaListSplit---"+countSql);
CommonDAO dao = null;
try{
dao = new CommonDAO(jndi);
rowNum = PageDiv.getCount(countSql.toString(), dao);
pageBean.setPageInfo(rowNum, pageSize);
//執行查找
ResultSet rs = PageDiv.getResultSet(pageNo, pageSize, rowNum, sql.toString(), dao);
for (int i = 0; i < pageSize && rs.next(); i++) {
//從結果集中讀取數據
arr.add(readDataFromRs(rs));
}
}catch( Exception ex ){
ex.printStackTrace();
}finally{
dao.destroy();
}
pageBean.setList(arr);
return true;
}
/**
* 讀取值對象列表
* @param rs 結果集
* @return 從結果集中讀取的對象列表
*/
private ArrayList readDataListFromRs(ResultSet rs) throws SQLException {
ArrayList arr = new ArrayList();
Area area = null;
try{
while (rs.next()) {
area = new Area();
//將字段值set到值對象中
area.setAreaId(rs.getString("area_id")); //區域ID
area.setAreaName(rs.getString("area_name")); //區域名稱
area.setAreaFatherId(rs.getString("area_father_id")); //所屬區縣
area.setAreaGrandfatherId(rs.getString("area_grandfather_id")); //所屬省市
arr.add(area);
}
}catch( Exception ex ){
ex.printStackTrace();
}
return arr;
}
/**
* 讀取單個值對象
* @param rs 結果集
* @return 按某列讀取的特定記錄的值對象
*/
private Area readDataFromRs(ResultSet rs) throws SQLException {
Area area = new Area();
try{
//將字段值set到值對象中
area.setAreaId(rs.getString("area_id")); //區域ID
area.setAreaName(rs.getString("area_name")); //區域名稱
area.setAreaFatherId(rs.getString("area_father_id")); //所屬區縣
area.setAreaGrandfatherId(rs.getString("area_grandfather_id")); //所屬省市
}catch( Exception ex ){
ex.printStackTrace();
}
return area;
}
/**
* 更新數據 用于數據更新語句 Insert，Update,Delete
* @param updateSql 數據庫更新語句
* @param logtype 數據庫操作類型
* @return 更新成功與否
*/
private boolean updateData(String updateSql, String logtype) {
int returnInt = -1;
boolean returnFlag = false;
CommonDAO dao = null;
try {
dao = new CommonDAO("jdbc/ccn");
returnInt = dao.excute(updateSql);
if (returnInt != -1) {
returnFlag = true;
}
}
catch (Exception ex) {
ex.printStackTrace();
}
finally {
dao.destroy();
}
// 寫入日志
if (log != null) {
log.setSql(updateSql);
log.setOperation(logtype);
OperatorLogger loggerUpdate = new OperatorLogger();
loggerUpdate.addLog(log);
}
return returnFlag;
}
/**
* 獲得按值對象查詢的查詢條件
* @param areaSearch 條件查詢的值對象
* @return sql查詢條件
*/
private StringBuffer getSqlwherBySearch(AreaSearch areaSearch ){
areaSearch = (AreaSearch)QuoteReplace.replace(areaSearch); //值對象中的單引號替換
String areaId = areaSearch.getAreaId();
String areaName = areaSearch.getAreaName();
String areaFatherId = areaSearch.getAreaFatherId();
String areaGrandfatherId = areaSearch.getAreaGrandfatherId();
StringBuffer sqlWhere = new StringBuffer(" ");
if (areaId != null && areaId.trim().length() != 0) {
sqlWhere.append(" and area_id like '%").append(areaId).append("%' ");
}
if (areaName != null && areaName.trim().length() != 0) {
sqlWhere.append(" and area_name like '%").append(areaName).append("%' ");
}
if (areaFatherId != null && areaFatherId.trim().length() != 0) {
sqlWhere.append(" and area_father_id like '%").append(areaFatherId).append("%' ");
}
if (areaGrandfatherId != null && areaGrandfatherId.trim().length() != 0) {
sqlWhere.append(" and area_grandfather_id like '%").append(areaGrandfatherId).append("%' ");
}
return sqlWhere;
}
/**
* 根據不同類別得到區域名稱
* @param areaSearch 條件查詢的值對象，areaType 區域類別如：城市，區，縣
* @return 符合條件的area集合
*/
public ArrayList getAreaInfo(AreaSearch areaSearch,String areaType){
ArrayList arr = null;
StringBuffer sqlBuf = new StringBuffer(50);
String areaId = areaSearch.getAreaId();
//得到省市名稱
if(areaType.equals("sheng")){
sqlBuf.append("select * from area where area_grandfather_id = area_id and area_id =area_father_id ");
}
//得到市名稱
if(areaId != null && areaType.equals("shi")){
sqlBuf.append("select * from area where area_grandfather_id = '"+areaId+"' and area_id=area_father_id and area_grandfather_id!=area_father_id");
}
//得到區縣名稱
if(areaId != null && areaType.equals("qu")){
sqlBuf.append("select * from area where area_father_id = '"+areaId+"' and area_id != area_father_id" );
}
sqlBuf.append( " order by area_id ");
logger.warn("---sql:getAreaListSplit---"+sqlBuf);
CommonDAO dao = null;
ResultSet rs = null;
try{
dao = new CommonDAO(jndi);
rs = dao.query(sqlBuf.toString());
//讀取結果集信息
arr = this.readDataListFromRs(rs);
}catch( Exception ex ){
ex.printStackTrace();
}finally{
dao.destroy();
dao=null;
sqlBuf = null;
}
return arr;
}
}
- 3 回答
- 0 關注
- 607 瀏覽
添加回答
舉報
0/150
提交
取消