Service/Daoクラス

// 主キー1000のデータを取得
Customer customer = customerDao.get(1000, true);
// データを更新
customer.setName("ジャスミン太郎");
customerDao.update(customer);
// データを登録
Customer customer2 = new Customer(customer);
customer2.setCustomerid(1001);
customerDao.save(customer2);
// 主キー2000のデータを削除
customerDao.deleteById(2000, true);

@Autowired
@Qualifier("CustomerEntityService")
protected JFCEntityService<Customer, Integer> customerEntityService;

@Autowired
@Qualifier("CustomerDao")
protected JFCHibernateDao<Customer, Integer> customerDao;

@Autowired
@Qualifier("CustomerHelper")
protected EntityHelper<Customer, Integer> customerHelper;

import jp.jasminesoft.jfc.service.JFCEntityService;
...
JFCEntityService<Customer, Integer> entityService =
  (JFCEntityService<Customer, Integer>)p.appctx.getBean("CustomerEntityService");

import jp.jasminesoft.jfc.service.JFCEntityService;
...
Customer[] customer_ary = null;
CustomerC cond = new jp.jasminesoft.wagby.model.customer_c.CustomerC();
((CustomerCHelper)p.appctx.getBean("CustomerCHelper")).initialize(cond, p);
cond.setName(name);// ここでは顧客名を検索条件に設定した。
JFCEntityService<Customer, String> entityService = 
    (JFCEntityService<Customer, String>)p.appctx.getBean("CustomerEntityService");
FinderContext<CustomerC> finderContext = new FinderContext<CustomerC>();
finderContext.setCondition(cond);
finderContext.setPageSize(-1);// 無制限
finderContext.setCriteriaConverter((CustomerCriteriaConverter)
    p.appctx.getBean("CustomerCriteriaConverter"));
List<Customer> coll = entityService.find(finderContext);
if (coll != null && coll.size() > 0) {
    customer_ary = (Customer[])coll.toArray(new Customer[0]);
}

import jp.jasminesoft.jfc.service.JFCEntityService;
...
Customer customer = null;
try {
    JFCEntityService<Customer, Integer> entityService =
        (JFCEntityService<Customer, Integer>)p.appctx.getBean("CustomerEntityService");
    customer = entityService.findById(customerid, true);//主キーを指定。ロックを取得する。
} catch (Exception e) {
    String errmsg = 
        DbBaseController.convertErrorMessage(e, 
            new String[][] {
                { "customerid", JFCUtils.getRValue("customer.customerid", p.locale) }
            });
    if (errmsg == null) {
        errmsg = "";
    }
    Object[] ep = { errmsg };
    p.errors.addJfcerror
         (errorManager.getJfcerror("customer.error.dbaccess", ep, p.locale));
}
// このあと customer を更新することを想定。更新時に取得したロックは解放される。
// (省略)

import jp.jasminesoft.jfc.service.JFCEntityService;
...
JFCEntityService<Customer, Integer> entityService =
  (JFCEntityService<Customer, Integer>)p.appctx.getBean("CustomerEntityService");
// findById メソッドを経由してオブジェクトを取得、そのときにロックを取得した。
Customer customer = entityService.findById(customerid, true);//主キー
// customer オブジェクトの内容を変更
// (省略)
// 更新
entityService.update(customer);
//entityService.update(customer, false); 未ロックのオブジェクトを更新する場合。非推奨。

// この方式で取得した criteria は、モデル定義で設定した暗黙条件も適用されない。
// (後述する CriteriaConverter を使う方式では、暗黙条件が適用される。)
CustomerMeta meta = new CustomerMeta();
DetachedCriteria criteria = DetachedCriteria.forClass(Customer.class);
// customerid を検索するための Criteria を組み立てる(数値の範囲検索)。
criteria.between(meta.customerid,
        condition.getCustomerid1jshparamAsInteger(),
        condition.getCustomerid2jshparamAsInteger());
// deptname を検索するための Criteria を組み立てる(部分一致検索)。
criteria.like(meta.deptname, condition.getDeptname());
// 繰返し項目 email を検索するための Criteria を組み立てる。
criteria.like(meta.email, condition.getEmail());
// 繰り返しコンテナ内の項目 rdate を検索するための Criteria を組み立てる。
criteria.between(meta.rdate, condition.getRdate1jshparam(),
        condition.getRdate2jshparam());
// 会社名(降順)、顧客ID(昇順) でソートする。
// SQL : ORDER BY companyname DESC, customerid ASC
// Order はhibernateが提供するクラス。(org.hibernate.criterion.Order)
criteria.addOrder(
       new Order[] {Order.desc(meta.companyname.name()),
               Order.asc(meta.customerid.name())});
Criteria executableCriteria
        = criteria.getExecutableCriteria(getCurrentSession());
@SuppressWarnings("unchecked")
List<Customer> results = executableCriteria.list();

// CriteriaConverter インスタンスを作成
CustomerCriteriaConverter converter
        = (CustomerCriteriaConverter) p.appctx.getBean(
                "CustomerCriteriaConverter");
// Condition を Criteria に変換
DetachedCriteria criteria = converter.convert(condition, sortKey);
// Criteria を使って検索を実行する。(daoオブジェクトは事前に用意されたものとする)
List<Customer> results = dao.findByCriteria(criteria);
// Service を利用することもできる。(serviceオブジェクトは事前に用意されたものとする)
//List<Customer> results = service.find(criteria);

/** CriteriaConverter インスタンスを作成 */
@Autowired
@Qualifier("CustomerCriteriaConverter")
protected CriteriaConverter<CustomerC> converter;

CustomerCriteriaConverter converter
        = (CustomerCriteriaConverter) p.appctx.getBean(
                "CustomerCriteriaConverter");
DetachedCriteria criteria = converter.convert(condition, sortKey);
// 先頭の 10 件を取得
List<Customer> results = dao.findByCriteria(criteria, 0, 10);
// ...
// 次の 10 件を取得
results = dao.findByCriteria(criteria, 10, 10);

// FinderContext インスタンスを作成
FinderContext<CustomerC> finderContext = new FinderContext<CustomerC>();
// Condition をセット
finderContext.setCondition(condition);
// ページサイズをセット( 0 をセットすると無制限となります)
finderContext.setPageSize(10);
// CriteriaConverter をセット
finderContext.setCriteriaConverter(
        (CustomerCriteriaConverter) p.appctx.getBean(
                "CustomerCriteriaConverter"));
// 先頭の 10 件を取得
List<Customer> results = dao.find(finderContext);
// 次の 10 件を取得
finderContext.next();
results = dao.find(finderContext);
// 最後のページのデータを取得
finderContext.last();
results = dao.find(finderContext);

// FinderContext インスタンスを作成
FinderContext<CustomerC> finderContext = new FinderContext<CustomerC>();
// Condition をセット
finderContext.setCondition(condition);
// CriteriaConverter をセット
finderContext.setCriteriaConverter(
        (CustomerCriteriaConverter) p.appctx.getBean(
                "CustomerCriteriaConverter"));
int size = dao.count(finderContext);

Zaiko.Key key = new Zaiko.Key();
key.setPkey1(xxx);/* xxx には、主キーの値が入ります */
key.setPkey2(yyy);/* yyy には、主キーの値が入ります */
Zaiko zaiko = zaikoEntityService.findById(key,true);/* 第二引数がtrueのときロックをかける */

public class MyCustomerDao extends CustomerDao {
    /** {@inheritDoc} */
    @Override
    public Customer get(Integer pkey) {
        getCurrentSession().doWork(new Work() {
            public void execute(Connection connection) throws SQLException {
                CallableStatement st = null;
                ResultSet rs = null;
                try {
                    // ストアドプロシージャ呼び出し
                    st = connection.prepareCall("{?= CALL POWER(2, 3)}");
                    st.execute();
                    rs = st.getResultSet();
                    if (rs.next())  {
                      System.out.println(rs.getInt(1)); // 結果の出力。
                    }
                } finally {
                    DbUtils.closeQuietly(st);
                    DbUtils.closeQuietly(rs);
                }
            }
        });
        return get(pkey, true);
    }
}

   @Override
   public void afterUpdate(Model1 entity, final ActionParameter p) {
       org.hibernate.Session sess = jp.jasminesoft.jfc.app.HibernateUtil.openSession();
       try {
           sess.doWork(new Work() {
               (ストアドプロシージャ呼び出し、またはSQL処理。)
           });
       } finally {
           sess.close();
       }
       super.afterUpdate(entity, p);
   }

   @Override
   public void afterUpdate(Model1 entity, final ActionParameter p) {
       org.hibernate.Session sess = jp.jasminesoft.jfc.app.HibernateUtil.openSession();
       try {
           Object o = sess.createSQLQuery(
               "SELECT COUNT(*) FROM \"juser\"").uniqueResult();
           System.out.println(o);
       } finally {
           sess.close();
       }
       super.afterUpdate(entity, p);
   }

public class MyModel1Helper extends Model1Helper {
   @Autowired
   @Qualifier("RequiredTransactionTemplate")
   protected TransactionTemplate requiredTransactionTemplate;
   public void initialize(Model1 model1, ActionParameter p)
       requiredTransactionTemplate.execute(
               new TransactionCallbackWithoutResult() {
                   @Override
                   protected void doInTransactionWithoutResult(
                           TransactionStatus status) {
                       // コードを記述する。model1 というオブジェクト(インスタンス)を利用できる。
                       // ActionParameter のインスタンス p も利用できる。
                   }
               });
   }

package jp.jasminesoft.wagby.controller.customer;
import java.io.IOException;
import javax.servlet.ServletException;
import jp.jasminesoft.jfc.ActionParameter;
import jp.jasminesoft.jfc.core.exception.BusinessLogicException;
import jp.jasminesoft.jfc.error.Jfcerror;
import jp.jasminesoft.jfc.service.JFCEntityService;
import jp.jasminesoft.util.ExcelFunction;
import jp.jasminesoft.wagby.app.jnews.JnewsHelper;
import jp.jasminesoft.wagby.model.jnews.Jnews;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;
/**
 * ShowCustomerController のカスタマイズクラスです。
 *
 * @author JasmineSoft
 * @version $Revision$ $Date$
 */
@Controller
public class MyShowCustomerController extends ShowCustomerController {
    /** {@inheritDoc} */
    @Override
    public String do_original(ActionParameter p)
        throws IOException, ServletException, SecurityException {
        if ("Original1".equals(p.action)) {
            return do_myprocess1(p);
        }
        return null;
     }
    /**
     * オリジナル処理を実行します。
     * @param p {@link ActionParameter}
     * @return view
     */
    public String do_myprocess1(final ActionParameter p)
            throws IOException, ServletException {
        try {
            // Spring が提供する TransactionTemplate を使って、
            // @Transactional アノテーションを用いずにプログラム実装による
            // トランザクション機能を実現します。
            TransactionTemplate transactionTemplate = p.appctx.getBean(
                    "RequiredTransactionTemplate", TransactionTemplate.class);
            // トランザクション処理結果の戻り値が必要な場合は
            // TransactionCallback クラスを利用します。
            // 今回は戻り値が不要なので TransactionCallbackWithoutResult クラス
            // を使っています。
            transactionTemplate.execute(new TransactionCallbackWithoutResult() {
                /** {@inheritDoc} */
                @Override
                protected void doInTransactionWithoutResult(
                        TransactionStatus status) {
                    // トランザクションが開始された状態で本メソッドが実行され、
                    // メソッド内で Exception が発生すると自動的にロールバック
                    // されます。Exception が発生せずに本メソッドが正常終了する
                    // と自動的にコミットされます。
                    JnewsHelper helper = p.appctx.getBean(
                            "JnewsHelper", JnewsHelper.class);
                    @SuppressWarnings("unchecked")
                    JFCEntityService<Jnews, Integer> service
                            = (JFCEntityService<Jnews, Integer>) p.appctx
                                    .getBean("JnewsEntityService");
                    // 1件目のデータ登録
                    Jnews jnews = new Jnews();
                    helper.initialize(jnews, p);
                    jnews.setLimitdate(ExcelFunction.TODAY());
                    jnews.setTitle("お知らせ1");
                    service.insert(jnews);
                    // 2件目のデータ登録
                    jnews = new Jnews();
                    helper.initialize(jnews, p);
                    jnews.setLimitdate(ExcelFunction.TODAY());
                    jnews.setTitle("お知らせ2");
                    service.insert(jnews);
                }
            });
        } catch (Exception e) {
            Jfcerror error = new Jfcerror();
            error.setContent("エラーが発生しました。" + e.getMessage());
            p.errors.addJfcerror(error);
        }
        // 元の画面へ遷移する。
        String id = p.request.getParameter("customerid");
        return "redirect:showCustomer.do?customerid=" + id;
    }
}

org.hibernate.Session session = p.appctx.getBean("sessionFactory").getCurrentSession();

package jp.jasminesoft.wagby.app.syukko;
import jp.jasminesoft.jfc.app.EntityHelper;
import jp.jasminesoft.jfc.core.exception.BusinessLogicException;
import jp.jasminesoft.jfc.service.JFCEntityService;
import jp.jasminesoft.wagby.model.syukko.Syukko;
import jp.jasminesoft.wagby.model.zaiko.Zaiko;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
/**
 * MySyukkoEntityService.
 *
 * @author JasmineSoft
 * @version $Revision$ $Date$
 */
public class MySyukkoEntityService extends SyukkoEntityService {
    /** ZaikoEntityService */
    @Autowired
    @Qualifier("ZaikoEntityService")
    protected JFCEntityService<Zaiko, Integer> zaikoEntityService;
    /** ZaikoHelper */
    @Autowired
    @Qualifier("ZaikoHelper")
    protected EntityHelper<Zaiko, Integer> zaikoHelper;
    /** {@inheritDoc} **/
    @Override
   protected void updateRelatedModelsInsertTransaction(Syukko syukko) {
       super.updateRelatedModelsInsertTransaction(syukko); // 既存処理の呼び出し
        // 在庫データの取得(第二引数をtrueとすることで悲観ロックを同時に行う)
        Zaiko zaiko = zaikoEntityService.findById(syukko.getShohinId(), true);
        // 業務処理 在庫チェック
        int suryou = zaiko.getSuryou();
        int syukkoNum = syukko.getSyukkoNum();
        if (suryou - syukkoNum < 0) {
            throw new BusinessLogicException("在庫 " + suryou + " に対して "
                    + syukkoNum + " を出庫しようとしました。");
        }
        // 業務処理 在庫数の調整処理
        zaiko.setSuryou(suryou - syukkoNum);
        zaikoEntityService.update(zaiko);
        // 更新処理の後処理(キャッシュの削除等)
        zaikoHelper.afterUpdate(zaiko,
                getActionParameterContainer().get());
    }
}

updateRelatedModelsInsertTransaction（E)

updateRelatedModelsUpdateTransaction（E)

updateRelatedModelsDeleteTransaction(E)

cascadeDelete(E)

org.hibernate.Session sess
   = jp.jasminesoft.jfc.app.HibernateUtil.openSession("sessionFactory2", p.appctx);

ServletContext sc = session.getServletContext();
WebApplicationContext appctx = WebApplicationContextUtils.getRequiredWebApplicationContext(sc);
org.hibernate.Session sess
   = jp.jasminesoft.jfc.app.HibernateUtil.openSession("sessionFactory2", appctx);