Service/Dao、ヘルパ、SQLの利用

var entityService = p.appctx.getBean(Service名);

var entityService = p.appctx.getBean("JuserEntityService");
var user = entityService.findById("user01"); /* 1件のデータを取得 */
print(user); /* デバッグ用ログ出力 */

var entityService = p.appctx.getBean("JuserEntityService");
var user = entityService.findById("user01", true); /* 1件のデータを取得 */
print(user); /* デバッグ用ログ出力 */
user.name = "ジャスミン太郎";
entityService.update(user); /* 更新 */

var customerClass = Java.type("jp.jasminesoft.wagby.model.customer.Customer");
// 空の状態の Customer オブジェクトを作成
var customer = new customerClass();
// 上記2行のコードを1行で記述することもできる。
//var customer = new Packages.jp.jasminesoft.wagby.model.customer.Customer();
 
var helper = p.appctx.getBean("CustomerHelper");
// helper#initialize() を利用することでリポジトリで定義した
// 初期値をセットする。
// 参考: https://wagby.com/wdn8/operation-script-init.html#initalize
helper.initialize(customer, p);
customer.customername = "ジャスミン太郎";
// EntityService を取得
var service = p.appctx.getBean("CustomerEntityService");
// customer データを登録
service.insert(customer);

var PessimisticLockException = Java.type("javax.persistence.PessimisticLockException");
...
try {
  var entityService = p.appctx.getBean("JuserEntityService");
  var user = entityService.findById("user01"); /* 1件のデータを取得 */
  print(user);
} catch (e) {
  if (e instanceof PessimisticLockException) { /* ロック取得失敗 */
    print("lock error " + e);
  } else { /* その他の例外 */
    print("error " + e);
  }
  throw e;
} finally {
}

var dao = p.appctx.getBean(Dao名);

var dao = p.appctx.getBean("JuserDao");
var user = dao.get("admin", true); /* 1件のデータを取得 */
print(user); /* デバッグ用ログ出力 */
user.name = "ジャスミン太郎";
dao.update(user); /* 更新 */

var IPresentationHelper = Java.type("jp.jasminesoft.jfc.IPresentationHelper");
var helperClass = p.appctx.getBean("QuotationPHelper");
var po = helperClass.s2p(quotation, p, IPresentationHelper.SHOW);
print(po);

var entityService = p.appctx.getBean("JuserEntityService");
var user = entityService.findById("user01", true);
if (user.kind == 1) {
  user.name = "ジャスミン太郎";
  entityService.update(user);
}

var LockUtils = Java.type("jp.jasminesoft.jfc.core.util.LockUtils");
var userDaoHelper = p.appctx.getBean("JuserDaoHelper");
var entityService = p.appctx.getBean("JuserEntityService");
var user = entityService.findById("user01");
if (user.kind == 1) {
  try {
    LockUtils.lock(user, userDaoHelper);/*ロック取得*/
    user.name = "ジャスミン太郎";
    entityService.update(user);
  } catch (e) {
    throw e;/*ロールバックのため*/
  } finally {
    LockUtils.release(user, userDaoHelper);/*ロック解放*/
  }
}

var PessimisticLockException = Java.type("javax.persistence.PessimisticLockException");
...
try {
  LockUtils.lock(user, userDaoHelper);/*ロック取得*/
  user.name = "ジャスミン太郎";
  entityService.update(user);
} catch (e if e instanceof PessimisticLockException) {
  print("lock error " + e);
  throw e;
} catch (e) {
  print("error " + e);
  throw e;
} finally {
  LockUtils.release(user, userDaoHelper);/*ロック解放*/
}

var criteriaConverter = p.appctx.getBean("Model1CriteriaConverter");
var criteria = criteriaConverter.defaultCriteria();

var Model1Meta = Java.type("jp.jasminesoft.wagby.model.model1.Model1Meta");
var model1Meta = new Model1Meta();
criteria.eq(model1Meta.item1, 1000); /* item1 の値が 1000 のデータで絞り込む */

var list = Model1Service.find(criteria);
if (list !== null && list.size() > 0) {
  // list から 1 つずつオブジェクトを取り出す
  for (var i=0; i<list.size(); i++) {
    var m = list.get(i);
    print(m);
  }
}

var OrderClass = Java.type("org.hibernate.criterion.Order");
var order = OrderClass.desc(Model1Meta.start_date.name());
criteria.addOrder(order);/* 並べ替え条件の追加 */
/*criteriaを使って検索する*/
...

var OrderClass = Java.type("org.hibernate.criterion.Order");
var CustomerMetaClass = Java.type("jp.jasminesoft.wagby.model.customer.CustomerMeta");
var customerMeta = new CustomerMetaClass();
var orders = [
    OrderClass.asc(customerMeta.companyname.name()),
    OrderClass.asc(customerMeta.deptname.name())
];
var criteriaConverter = p.appctx.getBean("CustomerCriteriaConverter");
/* 開発者が並び順を指定する */
var criteria = criteriaConverter.defaultCriteria(orders);

var DetachedCriteria = Java.type("jp.jasminesoft.jfc.hibernate.DetachedCriteria");
var CustomerClass = Java.type("jp.jasminesoft.wagby.model.customer.Customer");
var criteria = DetachedCriteria.forClass(CustomerClass.class);

var Zaiko = Java.type("jp.jasminesoft.wagby.model.zaiko.Zaiko");
var key = new Zaiko.Key();
key.pkey1 = xxx;/* xxx には、主キーの値が入ります */
key.pkey2 = yyy;/* yyy には、主キーの値が入ります */
var zaiko = zaikoEntityService.findById(key,true);/* 第二引数がtrueのときロックをかける */

throw new Packages.jp.jasminesoft.jfc.core.exception.BusinessLogicException("エラーメッセージ");

var suryou = product4s.stock;
var syukko_num = precord.PNumber;
/*print("suryou="+suryou+",syukko_num="+syukko_num);*/
if (suryou - syukko_num < 0) {
    return precord.PName + "の在庫 "+suryou+" に対して "+syukko_num+" を出庫しようとしました。";
}
product4s.stock = suryou - syukko_num;
return null;

var entityService = p.appctx.getBean("SalesslipEntityService");
var newTransactionEntityService = entityService.newTransactionEntityService();/*別トランザクションになる*/
var o_salesslip = newTransactionEntityService.findById(salesslip.id, false);/* salesslip.idは主キー */
var o_precords = o_salesslip.precord;
var o_precord;
for (var i=0; i<o_precords.length; i++) {
    o_precord = o_precords[i];
    if (o_precord.PNo == precord.PNo) {
        break;
    }
}
if (o_precord !== null) {
    var suryou = product4s.stock;
    var syukko_num = precord.PNumber - o_precord.PNumber;
    /*print("now suryou="+suryou+",syukko_num_diff="+syukko_num);*/
    if (syukko_num !== 0) {
        if (suryou - syukko_num < 0) {
        return precord.PName + "の在庫 "+suryou+" に対して "+syukko_num+" を出庫しようとしました。";
        }
        product4s.stock = suryou - syukko_num;
    }
}
return null;

var DataBindingContext = Java.type("jp.jasminesoft.jfc.dao.DataBindingContext");
var dao = p.appctx.getBean("SalesslipDao");
var dataBindingContext = new DataBindingContext();
var targetItemSet = new java.util.HashSet();
targetItemSet.add("customerName");/* 解決したい参照連動項目 */
dataBindingContext.setTargetItemSet(targetItemSet);
var o_salesslip = dao.get(salesslip.id, true, dataBindingContext);/* 第3引数に指定 */

var DataBindingContext = Java.type("jp.jasminesoft.jfc.dao.DataBindingContext");
var dao = p.appctx.getBean("SalesslipDao");
var dataBindingContext = new DataBindingContext();
var targetItemSet = new java.util.HashSet();
dataBindingContext.setTargetItemSet(targetItemSet);/* 項目を明示しない */
var o_salesslip = dao.get(salesslip.id, true, dataBindingContext);/* 第3引数に指定 */

var DataBindingContext = Java.type("jp.jasminesoft.jfc.dao.DataBindingContext");
var dao = p.appctx.getBean("SalesslipDao");
var dataBindingContext = new DataBindingContext();
dataBindingContext.setTargetItemSet(new java.util.HashSet());/* 項目を明示しない */
var o_salesslip = dao.get(salesslip.id, true, dataBindingContext);/* 第3引数に指定 */
print(o_salesslip);/* コンソールに出力。確認用 */
var o_precords = o_salesslip.precord;
var o_precord;
for (var i=0; i<o_precords.length; i++) {
    o_precord = o_precords[i];
    if (o_precord.PNo == precord.PNo) {
        break;
    }
}
if (o_precord !== null) {
    var suryou = product4s.stock;
    var syukko_num = precord.PNumber - o_precord.PNumber;
    /*print("now suryou="+suryou+",syukko_num_diff="+syukko_num);*/
    if (syukko_num !== 0) {
        if (suryou - syukko_num < 0) {
        return precord.PName + "の在庫 "+suryou+" に対して "+syukko_num+" を出庫しようとしました。";
        }
        product4s.stock = suryou - syukko_num;
    }
}
return null;

try {
  if (session !== null) {
    /*旧データ読み込み*/
    var sql =
      "SELECT \"p_number\" FROM \"salesslip$precord\"" +
      " WHERE \"id\"=" + salesslip.id + " AND" +
      " \"precordjshid\"=" + (precord.PNo - 1);
    /*print("sql="+sql);*/
    var o_PNumber = session.createSQLQuery(sql).uniqueResult();
    /*print("o_PNumber="+o_PNumber);*/
    var suryou = product4s.stock;
    var syukko_num = precord.PNumber - o_PNumber;
    print("now suryou="+suryou+",syukko_num_diff="+syukko_num);
    if (syukko_num !== 0) {
      if (suryou - syukko_num < 0) {
        return precord.PName + "の在庫 "+suryou+" に対して "+syukko_num+" を出庫しようとしました。";
      }
      product4s.stock = suryou - syukko_num;
    }
  }
} catch (e) {
  e.printStackTrace();
}
return null;

function process() {
(ここに開発者独自のコードを記載してください。)
}

try {
  if (session !== null) {
    var o = session.createSQLQuery(
      "SELECT COUNT(*) FROM \"juser\"").uniqueResult();
    print("o="+o);/* デバッグ用 */
  }
} catch (e) {
  e.printStackTrace();
}

var HibernateUtil = Java.type("jp.jasminesoft.jfc.app.HibernateUtil");
var session = HibernateUtil.openSession();
try {
  /* session を利用した処理を実装する */
  ...
} catch (e) {
  e.printStackTrace();
} finally {
  if (session !== null) {
    session.close();/* 忘れないこと */
  }
}

try {
  // 戻り値がないパターン (更新なし、データ取得のみ）
  var call1 = "{CALL FOO()}";
  session.createSQLQuery(call1).executeUpdate();
  // 戻り値が1つのパターン (更新なし、データ取得のみ）
  var call2 = "{CALL BAR()}";
  var result = session.createSQLQuery(call2).uniqueResult();
  print(result);
  // 戻り値が複数のパターン (更新なし、データ取得のみ）  
  var call3 = "{CALL BAZ()}";
  var list = session.createSQLQuery(call3).list();
  print(list);
} catch(e) {
  e.printStackTrace();
}

var HibernateUtil = Java.type("jp.jasminesoft.jfc.app.HibernateUtil");
var session = HibernateUtil.openSession();
try {
  var tx = session.beginTransaction();
  var call = "{CALL POWER(2, 3)}";
  var result = session.createSQLQuery(call).uniqueResult();
  print(result);
  tx.commit();
} catch(e) {
  e.printStackTrace();
  tx.rollback();
} finally {
  if (session !== null) {
    session.close();
  }
}

var JFCUtils = Java.type("jp.jasminesoft.jfc.JFCUtils");
var HibernateUtil = Java.type("jp.jasminesoft.jfc.app.HibernateUtil");
var Work = Java.type("org.hibernate.jdbc.Work");
var DbUtils = Java.type("org.apache.commons.dbutils.DbUtils");
var Types = Java.type("java.sql.Types");
var session = HibernateUtil.openSession();
try {
  /* トランザクションを開始する */
  var tx = session.beginTransaction();
  var out = null;
  var MyWork = Java.extend(Work, {
    execute: function(connection) {
      var st = null;
      try {
        // ストアドプロシージャ呼び出し (更新なし、データ取得のみ）
        st = connection.prepareCall("{CALL XXX(?, ?)}");
        // IN パラメータの指定(1番目のパラメータ)
        st.setInt(1, id);
        // OUTパラメータの指定(2番目のパラメータ)
        st.registerOutParameter(2, Types.INTEGER);
        st.execute();
        // OUTパラメータの取得
        out = st.getInt(2);
      } finally {
        DbUtils.closeQuietly(st);
      }
    }
  });
  session.doWork(new MyWork());
  print(out);//デバッグ用
  /* コミットする */
  tx.commit();
} catch (e) {
  e.printStackTrace();
  tx.rollback();
} finally {
  if (session !== null) {
      session.close();
  }
}

var JFCUtils = Java.type("jp.jasminesoft.jfc.JFCUtils");
var HibernateUtil = Java.type("jp.jasminesoft.jfc.app.HibernateUtil");
var Work = Java.type("org.hibernate.jdbc.Work");
var DbUtils = Java.type("org.apache.commons.dbutils.DbUtils");
var Types = Java.type("java.sql.Types");
var HibernateUtil = Java.type("jp.jasminesoft.jfc.app.HibernateUtil");
var Work = Java.type("org.hibernate.jdbc.Work");
var DbUtils = Java.type("org.apache.commons.dbutils.DbUtils");
var Types = Java.type("java.sql.Types");
var session = HibernateUtil.openSession();
try {
  var tx = session.beginTransaction();
  var MyWork = Java.extend(Work, {
    execute: function(connection) {
      var st = null;
      try {
        st = connection.prepareCall("EXEC TEST1 ?, ?, ?");
        st.setQueryTimeout(10000); /* タイムアウトの設定 */
        st.registerOutParameter(3, Types.INTEGER);
        st.setInt(1, 4);
        st.setInt(2, 5);
        st.execute();
        print("result:[" + st.getInt(3) + "]");
      } catch (e) {
        e.printStackTrace();
      } finally {
        DbUtils.closeQuietly(st);
      }
    }
  });
  print("Original1 procedure execute start time: ", new Date());
  session.doWork(new MyWork());
  print("Original1 procedure execute end time: ", new Date());
  print("");
  tx.commit();
} catch (e) {
  e.printStackTrace();
  tx.rollback();
} finally {
  if (session !== null) {
      session.close();
  }
}

var LockUtils = Java.type("jp.jasminesoft.jfc.core.util.LockUtils");
var model1DaoHelper = p.appctx.getBean("Model1DaoHelper");
var lockName = model1DaoHelper.getLockName();
...
try {
  LockUtils.lock(lockName, "1000", p);/*ロック取得*/
  ...
  // 更新処理
  ...
} catch (e) {
  throw e;/*ロールバックのため*/
} finally {
  LockUtils.release(lockName, "1000", p);/*ロック解放*/
}

var LockUtils = Java.type("jp.jasminesoft.jfc.core.util.LockUtils");
var model1DaoHelper = p.appctx.getBean("Model1DaoHelper");
var lockName = model1DaoHelper.getLockName();
...
try {
  LockUtils.modelLock(lockName, p);/*ロック取得*/
  ...
  // 更新処理
  ...
} catch (e) {
  throw e;/*ロールバックのため*/
} finally {
  LockUtils.releaseModelLock(lockName, p);/*ロック解放*/
}

// ... データベースの更新が終了した ...
var CacheManagerClass = Java.type("jp.jasminesoft.wagby.app.CacheManager");
var cman = CacheManagerClass.getInstance(p);
cman.clearModel1();

function process() {
  var ExcelFunction = Java.type("jp.jasminesoft.util.ExcelFunction");
  var Jfcerror = Java.type("jp.jasminesoft.jfc.error.Jfcerror");
  // トランザクション処理結果の戻り値が必要な場合は
  // TransactionCallback クラスを利用します。
  // 今回は戻り値が不要なので TransactionCallbackWithoutResult クラス
  // を使っています。
  var TransactionCallbackWithoutResult = Java.type(
      "org.springframework.transaction.support.TransactionCallbackWithoutResult");
  // TransactionCallbackWithoutResult クラスの doInTransactionWithoutResult()
  // メソッドをオーバーライドします。
  var MyTransactionCallbackWithoutResult
      = Java.extend(TransactionCallbackWithoutResult, {
          doInTransactionWithoutResult: function(status) {
            // トランザクションが開始された状態で本メソッドが実行され、
            // メソッド内で Exception が発生すると自動的にロールバック
            // されます。Exception が発生せずに本メソッドが正常終了する
            // と自動的にコミットされます。
            var helper = p.appctx.getBean("JnewsHelper");
            var service = p.appctx.getBean("JnewsEntityService");
            // 1件目のデータ登録
            var jnews = new Packages.jp.jasminesoft.wagby.model.jnews.Jnews();
            helper.initialize(jnews, p);
            jnews.limitdate = ExcelFunction.TODAY();
            jnews.title = "お知らせ1";
            service.insert(jnews);
            // 2件目のデータ登録
            jnews = new Packages.jp.jasminesoft.wagby.model.jnews.Jnews();
            helper.initialize(jnews, p);
            jnews.limitdate = ExcelFunction.TODAY();
            jnews.title = "お知らせ2";
            service.insert(jnews);
          }
      });
  try {
    // Spring が提供する TransactionTemplate を使って、
    // @Transactional アノテーションを用いずにプログラム実装による
    // トランザクション機能を実現します。
    var transactionTemplate = p.appctx.getBean("RequiredTransactionTemplate");
    transactionTemplate.execute(new MyTransactionCallbackWithoutResult());
  } catch (e) {
    var error = new Jfcerror();
    error.content = "エラーが発生しました。" + e.message;
    p.errors.addJfcerror(error);
  }
  // 元の画面へ遷移する。
  var id = p.request.getParameter("customerid");
  return "redirect:showCustomer.do?customerid="+id;
}

var session = p.appctx.getBean("sessionFactory").getCurrentSession();