package com.cntytz;

import weaver.conn.RecordSet;
import weaver.conn.RecordSetDataSource;
import weaver.general.BaseBean;
import weaver.interfaces.workflow.action.Action;
import weaver.soa.workflow.request.RequestInfo;

/**
 * 测试
 *
 * @author tjx
 * @date 2020/4/15
 */
public class MyAction extends BaseBean implements Action {
    @Override
    public String execute(RequestInfo requestInfo) {

        RecordSet record = new RecordSet();
        record.execute("SELECT count(*) as cc from uf_gcbagl");

        while (record.next()) {
            String counthrm = record.getString("cc");
            writeLog("-----tjx-db-test: " + counthrm);
        }
        requestInfo.getRequestManager().setMessagecontent("我的信息提示：db:" + record.getCounts());
        return FAILURE_AND_CONTINUE;
    }
}