Examples of org.fto.jthink.jdbc.SQL

org.fto.jthink.jdbc.SQL
用于描述一个SQL语句。此SQL语句对象包含有SQL的相关信息，SQL语句类型，SQL语句串，SQL语句中的值，以及用于SELECT语句的分页信息。SQL类型有如下值：UNDEFINED,UPDATE,SELECT,UNDEFINED_SP,UPDATE_SP,SELECT_SP。
```
 历史更新记录: 2005-07-15  创建此类型 2009-09-08  对于SQL语句增加StringBuffered支持 
```
@author wenjian @version 1.0 @since JThink 1.0

      /* 开始事务 */
      transaction.begin(); 
      
      message.setId(generateID());
      message.setSendTime(DateTimeHelper.formatDateTimetoString(DateTimeHelper.getSystemDate()));
      SQL sql = sqlBuilder.constructSQLForInsert(message);
      
      /* 执行SQL语句 */
      sqlExecutor.execute(sql);
      
      /* 提交事务 */

View Full Code Here

      /* 条件 */
      Condition condition = new Condition();
      condition.add(new ConditionItem("ID","=", request.getParameter("ID")));
      
      /* 构建SQL语句 */
      SQL sql = sqlBuilder.constructSQLForSelect("Messages", column, condition); 
      /* 执行SQL语句,并返回结果 */
      Iterator it = ((List)sqlExecutor.execute(sql, Message.class)).iterator();
      
      if(it.hasNext()){
        return (Message)it.next();

View Full Code Here

      message.setRevertContent(request.getParameter("RevertContent"));
      message.setReverter(request.getParameter("Reverter"));
      message.setRevertTime(DateTimeHelper.formatDateTimetoString(DateTimeHelper.getSystemDate()));
      message.setId(request.getParameter("ID"));
      
      SQL sql = sqlBuilder.constructSQLForUpdate(message);
      /* 执行SQL语句 */
      sqlExecutor.execute(sql);
      
      /* 提交事务 */
      transaction.commit();

View Full Code Here

      
//      Condition condition = new Condition();
//      condition.add(new ConditionItem("ID","=", request.getParameter("ID")));
      Message message = new Message();
      message.setId(request.getParameter("ID"));
      SQL sql = sqlBuilder.constructSQLForDelete(message);
      
      /* 执行SQL语句 */
      sqlExecutor.execute(sql);
      
      /* 提交事务 */

View Full Code Here

    }
    try{
      transaction.begin();
      
      /* 构建SQL语句 */
      SQL sql = sqlBuilder.constructSQLForCount("Messages", "*", "ROW_COUNT", null); 
      DataObject countDO = (DataObject)((List)sqlExecutor.execute(sql)).iterator().next();
      return Integer.parseInt(countDO.get("ROW_COUNT"));
      
    }finally{
      transaction.close();

View Full Code Here

  public List searchMessages() throws Exception{
    try{
      transaction.begin();
      
      /* 构建SQL语句 */
      SQL sql = sqlBuilder.constructSQLForSelect("Messages", false, null, null, "", "SendTime desc", (getPageOffset()-1)*getPageRows(), getPageRows()); 
      /* 执行SQL语句,并返回结果 */
      return (List)sqlExecutor.execute(sql, Message.class);
      
    }finally{
      transaction.close();

View Full Code Here

      message.setSender(request.getParameter("Sender"));
      message.setEmail(request.getParameter("Email"));
      message.setContact(request.getParameter("Contact"));
      message.setIP(request.getServletRequest().getRemoteAddr());
      message.setSendTime(DateTimeHelper.formatDateTimetoString(DateTimeHelper.getSystemDate()));
      SQL sql = sqlBuilder.constructSQLForInsert(message);
      /* 执行SQL语句 */
      sqlExecutor.execute(sql);
      
      /* 提交事务 */
      transaction.commit();

View Full Code Here

      /* 条件 */
      Condition condition = new Condition();
      condition.add(new ConditionItem("ID","=", request.getParameter("ID")));
      
      /* 构建SQL语句 */
      SQL sql = sqlBuilder.constructSQLForSelect("Messages", column, condition); 
      /* 执行SQL语句,并返回结果 */
      Iterator it = ((List)sqlExecutor.execute(sql, Message.class)).iterator();
      
      if(it.hasNext()){
        return (Message)it.next();

View Full Code Here

      message.setRevertContent(request.getParameter("RevertContent"));
      message.setReverter(request.getParameter("Reverter"));
      message.setRevertTime(DateTimeHelper.formatDateTimetoString(DateTimeHelper.getSystemDate()));
      message.setId(request.getParameter("ID"));
      
      SQL sql = sqlBuilder.constructSQLForUpdate(message);
      /* 执行SQL语句 */
      sqlExecutor.execute(sql);
      
      /* 提交事务 */
      transaction.commit();

View Full Code Here

      
//      Condition condition = new Condition();
//      condition.add(new ConditionItem("ID","=", request.getParameter("ID")));
      Message message = new Message();
      message.setId(request.getParameter("ID"));
      SQL sql = sqlBuilder.constructSQLForDelete(message);
      
      /* 执行SQL语句 */
      sqlExecutor.execute(sql);
      
      /* 提交事务 */

View Full Code Here

0 1 2 3

TOP

Related Classes of org.fto.jthink.jdbc.SQL

org.fto.jthink.jdbc.ConditionTestCase

org.fto.jthink.jdbc.hsql.HsqlSQLBuilder

org.fto.jthink.jdbc.mssql.MssqlSQLBuilder

org.fto.jthink.jdbc.mysql.MysqlSQLBuilder

org.fto.jthink.jdbc.SampleFinder

org.fto.jthink.jdbc.SampleSender

org.fto.jthink.jdbc.SQLBuilderTestCase

org.fto.jthink.lang.ObjectBuffered

org.fto.jthink.lang.StringBuffered

org.fto.jthink.sample.mboard.MBoardBusinessBean

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.