package com.sp.person.sql.util; 
 
import java.sql.Connection; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.util.Map; 
import java.util.TreeMap; 
 
import javax.sql.DataSource; 
 
/** 
 * 常常有同事在問(wèn)JDBC 分頁(yè)查詢 這里給二個(gè)例子介紹一下 
 * JDBC 分頁(yè)查詢 
 * 分成二種方式希望對(duì)大家有所幫助 
 * 分另表示了absolute 與relative 的區(qū)別 
 * @see 這時(shí)用到一個(gè)數(shù)據(jù)源設(shè)計(jì)模式 
 * 數(shù)據(jù)源與數(shù)據(jù)庫(kù)連接沒(méi)有關(guān)系 
 * 例用接口回調(diào)的特性 
 * @author liuqing 
 * @version 1.0 
 * 
 */ 
public class JdbcUtil { 
 
 /** 
 * 數(shù)據(jù)源 
 */ 
 private DataSource dataSource; 
 
 /** 
 * 不否啟用多數(shù)據(jù)源 
 */ 
 private boolean isMultipleDataSource; 
 
 /** 
 * 有時(shí)一個(gè)系統(tǒng)可能要使用多個(gè)數(shù)據(jù)源,存放多個(gè)數(shù)據(jù)源 
 */ 
 private Map<String,DataSource> dataSources = new TreeMap<String,DataSource>(); 
 
 /** 
 * if true isMultipleDataSource is Key to DataSource 
 */ 
 private String dataSourceKey; 
 
 /** 
 * 默認(rèn)構(gòu)造器 
 */ 
 public JdbcUtil() { 
  
 } 
 
 /** 
 * 構(gòu)造器 Spring 的構(gòu)造器注入 
 * @param dataSource 
 */ 
 public JdbcUtil(DataSource dataSource) { 
 this.dataSource = dataSource; 
 } 
 
 /** 
 * JDBC 分頁(yè)查詢 
 * @param sql SQL 查詢語(yǔ)句 
 * @param firstSize 起始頁(yè) 
 * @param maxSize 返回?cái)?shù)據(jù)條數(shù) 
 * @return ResultSet 
 * @throws SQLException 
 */ 
 public ResultSet queryPageAbsolute(String sql, 
  int firstSize,int maxSize) throws SQLException { 
 PreparedStatement pre = this.getConn().prepareStatement(sql); 
 pre.setMaxRows(maxSize); 
 ResultSet rs = pre.executeQuery(); 
 rs.absolute(firstSize * maxSize); 
 return rs; 
 } 
 
 /** 
 * JDBC 分頁(yè)查詢 
 * @param sql SQL 查詢語(yǔ)句 
 * @param firstSize 起始頁(yè) 
 * @param maxSize 返回?cái)?shù)據(jù)條數(shù) 
 * @return ResultSet 返回結(jié)果集 
 * @throws SQLException 
 */ 
 public ResultSet queryPageRelative(String sql, 
  int firstSize,int maxSize) throws SQLException { 
 PreparedStatement pre = getConn().prepareStatement(sql); 
 pre.setMaxRows(maxSize); 
 ResultSet rs = pre.executeQuery(); 
 rs.relative(firstSize); 
 return rs; 
 } 
 
 /** 
 * 
 * @return Connection 
 * @throws SQLException 
 */ 
 private Connection getConn() throws SQLException { 
 //使用多數(shù)據(jù)源的情況 
 if (this.isMultipleDataSource) { 
  DataSource v_dataSource = this.queryDataSourceByKey(); 
  if (v_dataSource != null) { 
  return v_dataSource.getConnection(); 
  } 
 } 
 return this.dataSource.getConnection(); 
 } 
 /** 
 * 獲得多數(shù)據(jù)源方法 
 * @return DataSource 
 */ 
 public DataSource queryDataSourceByKey() { 
 for (Map.Entry<String, DataSource> ds:this.dataSources.entrySet()) { 
  if (ds.getKey().equals(dataSourceKey)) { 
  return ds.getValue(); 
  } 
 } 
 return null; 
 } 
 
 /** 
 * 獲得多數(shù)據(jù)源方法 
 * @return DataSource 
 */ 
 public DataSource queryDataSourceByKey(String useKey) { 
 for (Map.Entry<String, DataSource> ds:this.dataSources.entrySet()) { 
  if (ds.getKey().equals(useKey)) { 
  return ds.getValue(); 
  } 
 } 
 return null; 
 } 
 
 /** 
 * 數(shù)據(jù)源 
 */ 
 public DataSource getDataSource() { 
 return dataSource; 
 } 
 
 /** 
 * 數(shù)據(jù)源 setter 注入 
 */ 
 public void setDataSource(DataSource dataSource) { 
 this.dataSource = dataSource; 
 } 
 
 /** 
 * @return the isMultipleDataSource 
 */ 
 public boolean isMultipleDataSource() { 
 return isMultipleDataSource; 
 } 
 
 /** 
 * @param isMultipleDataSource the isMultipleDataSource to set 
 */ 
 public void setMultipleDataSource(boolean isMultipleDataSource) { 
 this.isMultipleDataSource = isMultipleDataSource; 
 } 
 
 /** 
 * @return the dataSources 
 */ 
 public Map<String, DataSource> getDataSources() { 
 return dataSources; 
 } 
 
 /** 
 * @param dataSources the dataSources to set 
 */ 
 public void setDataSources(Map<String, DataSource> dataSources) { 
 this.dataSources = dataSources; 
 } 
 
 /** 
 * 返回當(dāng)前使用的數(shù)據(jù)源 
 * @return the dataSourceKey 
 */ 
 public String getDataSourceKey() { 
 return dataSourceKey; 
 } 
 
 /** 
 * 要使用的數(shù)據(jù)源為 
 * @param dataSourceKey the dataSourceKey to set 
 */ 
 public void setDataSourceKey(String dataSourceKey) { 
 this.dataSourceKey = dataSourceKey; 
 } 
 
}