commit Session and adjust method

Author: daileyet

src/openthinks/libs/sql/dao/pool/ConnectionPool.java

@@ -35,7 +35,8 @@
  */
 public interface ConnectionPool {
 
-	String MAX_ACTIVE = "";
+	String MAX_ACTIVE = "MAX_ACTIVE";
+	String MAX_IDLE = "MAX_IDLE";
 
 	/**
 	 * request a {@link Connection}, maybe it is a new or it is already existed

src/openthinks/libs/sql/dao/pool/impl/SimpleConnectionPool.java

@@ -45,7 +45,6 @@
  *
  */
 public class SimpleConnectionPool implements ConnectionPool {
-	private static final Object MAX_IDLE = null;
 	private final ConcurrentLinkedQueue<Connection> connectionQueue;
 	private final Configurator configurator;
 	private final Lock lock;
@@ -198,6 +197,7 @@ public void shutdown() {
 		}
 	}
 
+	@Override
 	public boolean isShutdown() {
 		return rejectAction.get();
 	}

src/openthinks/libs/sql/dhibernate/Session.java

@@ -3,6 +3,7 @@
 import java.io.Serializable;
 import java.util.List;
 
+import openthinks.libs.sql.dao.BaseDao;
 import openthinks.libs.sql.data.Row;
 import openthinks.libs.sql.dhibernate.support.query.Query;
 import openthinks.libs.sql.entity.Entity;
@@ -14,13 +15,93 @@
 
 /**
  * 与数据库会话接口
- * 
+ * <p>Include high level and low level ways to access database<BR>
+ * <B>High level DAO API - auto generate SQL</B>
+ * <ul>
+ * <li>{@link #createQuery(Class)}
+ * <li>{@link #load(Class, Serializable)}
+ * <li>{@link #save(Object)}
+ * <li>{@link #update(Object)}
+ * <li>{@link #delete(Object)}
+ * <li>{@link #list(Class)}
+ * </ul>
+ * <B>Low level DAO API - manual generate SQL</B>
+ * <ul>
+ * <li>{@link #add(Condition)} {@link #add(String)} {@link #add(String, String[])}
+ * <li>{@link #createCondition()}
+ * <li>{@link #delete(Condition)} {@link #delete(String)} {@link #delete(String, String[])}
+ * <li>{@link #get(Class, Condition)} {@link #get(Class, String)} {@link #get(Class, String, String[])}
+ * <li>{@link #list(Condition)} {@link #list(String)} {@link #list(String, String[])}
+ * <li>{@link #list(Class, Condition)} {@link #list(Class, String)} {@link #list(Class, String, String[])}
+ * <li>{@link #update(Condition)} {@link #update(String)} {@link #update(String, String[])}
+ * </ul>
+ * </p>
  * @author dmj
  * @version 2010/11/19
  * 
  */
 public interface Session {
 
+	/**
+	 * 开启事务
+	 * 
+	 * @throws TransactionException
+	 *             事务异常
+	 */
+	public void beginTransaction() throws TransactionException;
+
+	/**
+	 * 提交事务
+	 * 
+	 * @throws TransactionException
+	 *             事务异常
+	 */
+	public void commit() throws TransactionException;
+
+	/**
+	 * 回滚事务
+	 * 
+	 * @throws TransactionException
+	 *             事务异常
+	 */
+	public void rollback() throws TransactionException;
+
+	/**
+	 * 关闭与数据库会话
+	 */
+	public void close();
+
+	/**
+	 * 取得日志记录器 logger
+	 * 
+	 * @return 日志记录器logger
+	 */
+	public Logger getLogger();
+
+	/**
+	 * 取得数据库连接配置器 configurator
+	 * 
+	 * @return 数据库连接配置器configurator
+	 */
+	public Configurator getConfigurator();
+
+	/**
+	 * judge database connection is auto-close after execute DML
+	 * @return Boolean
+	 */
+	public Boolean isAutoClose();
+
+	/**
+	 * controller database connection auto-close when after execute DML
+	 * 
+	 */
+	public void enableAutoClose();
+
+	public void disableAutoClose();
+
+	/*==========================================================================================
+	*	High level DAO API, recommend
+	*/
 	/**
 	 * create a {@link Query} for this given entity class
 	 * @param clz Class<T> entity class type
@@ -30,10 +111,9 @@ public interface Session {
 
 	/**
 	 * 根据id值获取clz类型的实体对象
-	 * 
 	 * @param clz
 	 *            实体类型clz<BR>
-	 *            1.{@link Entity}子类默认第一个属性为ID列<BR>
+	 *            1.{@link Entity}子类默认第一个属性为ID列,类名需与表名一致<BR>
 	 *            2.JPA标注的实体类标准 {@link javax.persistence.Id}
 	 * @param id Serializable
 	 *            主键值
@@ -44,79 +124,97 @@ public interface Session {
 	/**
 	 * 持久化对象,进行Insert
 	 * 
-	 * @param object
+	 * @param object T
+	 * 			    实体类型T<BR>
+	 *            1.{@link Entity}子类默认第一个属性为ID列,类名需与表名一致<BR>
+	 *            2.JPA标注的实体类标准 {@link javax.persistence.Id}
 	 */
 	public <T> void save(T object);
 
 	/**
 	 * 持久化对象,根据持久化的对象主键进行Update
-	 * 
-	 * @param object
+	 * 			    实体类型T<BR>
+	 *            1.{@link Entity}子类默认第一个属性为ID列,类名需与表名一致<BR>
+	 *            2.JPA标注的实体类标准 {@link javax.persistence.Id}
+	 * @param object T
 	 */
 	public <T> void update(T object);
 
 	/**
-	 * 
-	 * @param object
+	 * 删除对象,根据持久化的对象主键进行Delete
+	 * 			    实体类型T<BR>
+	 *            1.{@link Entity}子类默认第一个属性为ID列,类名需与表名一致<BR>
+	 *            2.JPA标注的实体类标准 {@link javax.persistence.Id}
+	 * @param object T
 	 */
 	public <T> void delete(T object);
 
+	/**
+	 * 返回所有相应实体类的集合列表<br>
+	 * 
+	 * @param clz
+	 *            查询的实体Class类型,<span style=color:red>可以不是Entity的子类</span><BR>
+	 *            1.{@link Entity}子类子类默认第一个属性为ID列,类名需与表名一致<BR>
+	 *            2.JPA注解方式
+	 * @since 2010/11/17
+	 * @return List<E> 任何实体类的集合列表
+	 */
+	public <T> List<T> list(Class<T> clz);
+
+	/*==========================================================================================
+	*	Low level DAO API, recommend 
+	*/
+
 	/**
 	 * 根据查询语句获取clz类型的实体对象
 	 * 
 	 * @param clz
-	 *            实体类型clz
+	 *            实体类型clz<BR>
+	 *            1.{@link Entity}子类<BR>
+	 *            2.JPA标注的实体类标准 {@link javax.persistence.Id}
 	 * @param sql
-	 *            标准查询语句,<span style=color:red;>不支持多表查询语句</span>
+	 *            完整标准查询语句,<span style=color:red;>不支持多表查询语句</span>
 	 * @return Object 数据库表所对应的实体对象
 	 */
 	public <T> T get(Class<T> clz, String sql);
 
-	public <T extends Entity> T get(Entity entity, String sql);
+	//	@Deprecated
+	//	public <T extends Entity> T get(Entity entity, String sql);
 
 	/**
 	 * 根据查询语句获取clz类型的实体对象
-	 * 
 	 * @param clz
-	 *            实体类型clz
+	 *            实体类型clz<BR>
+	 *            1.{@link Entity}子类<BR>
+	 *            2.JPA标注的实体类标准 {@link javax.persistence.Id}
 	 * @param sql
-	 *            标准查询语句,<span style=color:red;>不支持多表查询语句</span>
+	 *            完整标准查询语句,<span style=color:red;>不支持多表查询语句</span>
 	 * @param params
 	 *            sql语句依赖的参数数组
 	 * @return Object 数据库表所对应的实体对象
 	 */
 	public <T> T get(Class<T> clz, String sql, String[] params);
 
-	public <T extends Entity> T get(Entity entity, String sql, String[] params);
-
+	//	@Deprecated
+	//	public <T extends Entity> T get(Entity entity, String sql, String[] params);
 	/**
 	 * 根据查询语句获取clz类型的实体对象
 	 * 
 	 * @param clz
-	 *            实体类型clz
+	 *            实体类型clz<BR>
+	 *            1.{@link Entity}子类<BR>
+	 *            2.JPA标注的实体类标准 {@link javax.persistence.Id}
 	 * @param condition
-	 *            专用于生成带条件的sql语句的对象,<span style=color:red;>不支持多表查询</span>
+	 *            专用于生成带条件的完整查询语句的对象,<span style=color:red;>不支持多表查询</span>
 	 * @return Object 数据库表所对应的实体对象
 	 */
 	public <T> T get(Class<T> clz, Condition condition);
 
-	public <T extends Entity> T get(Entity entity, Condition condition);
-
-	/**
-	 * 返回所有相应实体类的集合列表<br>
-	 * 
-	 * @param clz
-	 *            查询的实体Class类型,<span style=color:red>可以不是Entity的子类</span><BR>
-	 *            1.{@link Entity}子类<BR>
-	 *            2.JPA注解方式
-	 * @since 2010/11/17
-	 * @return List<E> 任何实体类的集合列表
-	 */
-	public <T> List<T> list(Class<T> clz);
-
+	//	@Deprecated
+	//	public <T extends Entity> T get(Entity entity, Condition condition);
 	/**
 	 * 根据查询语句获取clz类型的实体对象对象列表
-	 * 
+	 * @see Session#list(Class, String, String[])
 	 * @param clz
 	 *            实体类型clz
 	 * @param sql
@@ -127,7 +225,7 @@ public interface Session {
 
 	/**
 	 * 根据查询语句获取clz类型的实体对象对象列表
-	 * 
+	 * @see BaseDao#list(Class, String, String[])
 	 * @param clz
 	 *            实体类型clz
 	 * @param sql
@@ -272,61 +370,4 @@ public interface Session {
 	 */
 	public int delete(Condition condition);
 
-	/**
-	 * 开启事务
-	 * 
-	 * @throws TransactionException
-	 *             事务异常
-	 */
-	public void beginTransaction() throws TransactionException;
-
-	/**
-	 * 提交事务
-	 * 
-	 * @throws TransactionException
-	 *             事务异常
-	 */
-	public void commit() throws TransactionException;
-
-	/**
-	 * 回滚事务
-	 * 
-	 * @throws TransactionException
-	 *             事务异常
-	 */
-	public void rollback() throws TransactionException;
-
-	/**
-	 * 关闭与数据库会话
-	 */
-	public void close();
-
-	/**
-	 * 取得日志记录器 logger
-	 * 
-	 * @return 日志记录器logger
-	 */
-	public Logger getLogger();
-
-	/**
-	 * 取得数据库连接配置器 configurator
-	 * 
-	 * @return 数据库连接配置器configurator
-	 */
-	public Configurator getConfigurator();
-
-	/**
-	 * judge database connection is auto-close after execute DML
-	 * @return Boolean
-	 */
-	public Boolean isAutoClose();
-
-	/**
-	 * controller database connection auto-close when after execute DML
-	 * 
-	 */
-	public void enableAutoClose();
-
-	public void disableAutoClose();
-
 }