Package cc.concurrent.mango.runtime

Examples of cc.concurrent.mango.runtime.RuntimeContext

102
103
104
105
106
107
108
109
110
111
112
        }
    }

    @Override
    public Object execute(Object[] methodArgs) {
        RuntimeContext context = buildRuntimeContext(methodArgs);
        if (isUseCache()) { // 先使用缓存，再使用db
            return isUseMultipleKeys() ?
                    multipleKeysCache(context, rowMapper.getMappedClass(), getSuffixClass()) :
                    singleKeyCache(context);
        } else { // 直接使用db
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
        }
    }

    @Override
    public Object execute(Object[] methodArgs) {
        RuntimeContext context = buildRuntimeContext(methodArgs);
        String sql = rootNode.getSql(context);
        Object[] args = rootNode.getArgs(context);
        Number r = executeDb(sql, args);
        if (isUseCache()) { // 如果使用cache，更新后需要从cache中删除对应的key或keys
            if (isUseMultipleKeys()) { // 多个key，例如：update table set name='ash' where id in (1, 2, 3);
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
            keys = new HashSet<String>(iterables.size() * 2);
        }
        List<Object[]> batchArgs = new ArrayList<Object[]>(iterables.size());
        List<String> sqls = new ArrayList<String>(iterables.size());
        for (Object obj : iterables) {
            RuntimeContext context = buildRuntimeContext(new Object[]{obj});
            if (keys != null) { // 表示使用cache
                keys.add(getCacheKey(context));
            }
            batchArgs.add(rootNode.getArgs(context));
            sqls.add(rootNode.getSql(context));
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
        }
    }

    @Override
    public Object execute(Object[] methodArgs) {
        RuntimeContext context = buildRuntimeContext(methodArgs);
        if (isUseCache()) { // 先使用缓存，再使用db
            return isUseMultipleKeys() ?
                    multipleKeysCache(context, rowMapper.getMappedClass(), getSuffixClass()) :
                    singleKeyCache(context);
        } else { // 直接使用db
View Full Code Here
TOP

Related Classes of cc.concurrent.mango.runtime.RuntimeContext

  • cc.concurrent.mango.runtime.operator.BatchUpdateOperator
  • cc.concurrent.mango.runtime.operator.QueryOperator
  • cc.concurrent.mango.runtime.operator.UpdateOperator
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.