• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java SqlMapExecutor类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.ibatis.sqlmap.client.SqlMapExecutor的典型用法代码示例。如果您正苦于以下问题:Java SqlMapExecutor类的具体用法?Java SqlMapExecutor怎么用?Java SqlMapExecutor使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



SqlMapExecutor类属于com.ibatis.sqlmap.client包,在下文中一共展示了SqlMapExecutor类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: batchDelete

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
/**
 * 
 * 批量删除指定SQL的数据
 * 
 * @author zhangshaobin
 * @created 2012-12-3 下午2:19:55
 *
 * @param sqlId	SQL语句ID
 * @param params	删除数据的参数集合;NOT NULL
 * @return	成功更新的记录数
 */
@Override
public int[] batchDelete(final String sqlId, final List<BaseEntity> params) {
	// 执行回调
	final SqlMapClientCallback<Object> callback = new SqlMapClientCallback<Object>() {
		// 实现回调接口
		@Override
		public Object doInSqlMapClient(final SqlMapExecutor executor) throws SQLException {
			// 开始批处理
			executor.startBatch();
			final int[] rtnDel = new int[params.size()];
			for (int i = 0; i < params.size(); i++) {
				//rtnDel[i] = executor.delete(sqlId, params.get(i));
				rtnDel[i] = executor.delete(sqlId, executeRouter(sqlId, params.get(i)));
			}
			// 执行批处理
			executor.executeBatch();
			return rtnDel;
		}
	};

	return (int[]) getWriteSqlMapClientTemplate().execute(callback);
}
 
开发者ID:AsuraTeam,项目名称:asura,代码行数:34,代码来源:BaseIbatisDaoContext.java


示例2: batchUpdate

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
/**
 * 
 * 批量更新指定SQL的数据
 *
 * @author zhangshaobin
 * @created 2012-11-5 下午7:36:32
 *
 * @param sqlId	SQL语句ID
 * @param params	SQL语句中占位符对应的值
 * @return	成功更新的记录数
 */
@Override
public int[] batchUpdate(final String sqlId, final List<? extends BaseEntity> params) {
	// 执行回调
	final SqlMapClientCallback<Object> callback = new SqlMapClientCallback<Object>() {
		// 实现回调接口
		@Override
		public Object doInSqlMapClient(final SqlMapExecutor executor) throws SQLException {
			// 开始批处理
			executor.startBatch();
			final int[] rtnUpd = new int[params.size()];
			for (int i = 0; i < params.size(); i++) {
				//rtnUpd[i] = executor.update(sqlId, params.get(i));
				rtnUpd[i] = executor.update(sqlId, executeRouter(sqlId, params.get(i)));
			}
			// 执行批处理
			executor.executeBatch();
			return rtnUpd;
		}
	};

	return (int[]) getWriteSqlMapClientTemplate().execute(callback);
}
 
开发者ID:AsuraTeam,项目名称:asura,代码行数:34,代码来源:BaseIbatisDaoContext.java


示例3: batchDelete

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
/**
 * 
 * 批量删除指定SQL的数据
 *
 * @author zhangshaobin
 * @created 2012-12-3 下午2:19:55
 *
 * @param sqlId	SQL语句ID
 * @param params	SQL语句中占位符对应的值
 * @return	成功更新的记录数
 */
public int[] batchDelete(final String sqlId, final List<BaseEntity> params) {
	// 执行回调
	SqlMapClientCallback<Object> callback = new SqlMapClientCallback<Object>() {
		// 实现回调接口
		public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			// 开始批处理
			executor.startBatch();
			int[] rtnDel = new int[params.size()];
			for (int i = 0; i < params.size(); i++) {
				rtnDel[i] = executor.delete(sqlId, params.get(i));
			}
			// 执行批处理
			executor.executeBatch();
			return rtnDel;
		}
	};

	return (int[]) template.execute(callback);
}
 
开发者ID:AsuraTeam,项目名称:asura,代码行数:31,代码来源:BaseIbatisDAO.java


示例4: batchUpdate

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
/**
 * 
 * 批量更新指定SQL的数据
 *
 * @author zhangshaobin
 * @created 2012-11-5 下午7:36:32
 *
 * @param sqlId	SQL语句ID
 * @param params	SQL语句中占位符对应的值
 * @return	成功更新的记录数
 */
public int[] batchUpdate(final String sqlId, final List<? extends BaseEntity> params) {
	// 执行回调
	SqlMapClientCallback<Object> callback = new SqlMapClientCallback<Object>() {
		// 实现回调接口
		public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			// 开始批处理
			executor.startBatch();
			int[] rtnUpd = new int[params.size()];
			for (int i = 0; i < params.size(); i++) {
				rtnUpd[i] = executor.update(sqlId, params.get(i));
			}
			// 执行批处理
			executor.executeBatch();
			return rtnUpd;
		}
	};

	return (int[]) template.execute(callback);
}
 
开发者ID:AsuraTeam,项目名称:asura,代码行数:31,代码来源:BaseIbatisDAO.java


示例5: testSqlMapClientTemplateWithNestedSqlMapSession

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
@Test
public void testSqlMapClientTemplateWithNestedSqlMapSession() throws SQLException {
	DataSource ds = mock(DataSource.class);
	final Connection con = mock(Connection.class);
	final SqlMapSession session = mock(SqlMapSession.class);
	SqlMapClient client = mock(SqlMapClient.class);

	given(client.openSession()).willReturn(session);
	given(session.getCurrentConnection()).willReturn(con);

	SqlMapClientTemplate template = new SqlMapClientTemplate();
	template.setDataSource(ds);
	template.setSqlMapClient(client);
	template.afterPropertiesSet();
	Object result = template.execute(new SqlMapClientCallback() {
		@Override
		public Object doInSqlMapClient(SqlMapExecutor executor) {
			assertTrue(executor == session);
			return "done";
		}
	});
	assertEquals("done", result);
}
 
开发者ID:deathspeeder,项目名称:class-guard,代码行数:24,代码来源:SqlMapClientTests.java


示例6: testAndVerifyQueryForList

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
protected final void testAndVerifyQueryForList(SqlMapExecutor executor) throws Exception {
    final String queryForListId = "queryForListId";
    executor.queryForList(queryForListId);
    executor.queryForList(queryForListId, new Object());
    executor.queryForList(queryForListId, 0, 1);
    executor.queryForList(queryForListId, new Object(), 0, 1);

    PluginTestVerifier verifier = PluginTestVerifierHolder.getInstance();
    Method queryForList1 = executor.getClass().getDeclaredMethod("queryForList", String.class);
    Method queryForList2 = executor.getClass().getDeclaredMethod("queryForList", String.class, Object.class);
    Method queryForList3 = executor.getClass()
            .getDeclaredMethod("queryForList", String.class, int.class, int.class);
    Method queryForList4 = executor.getClass().getDeclaredMethod("queryForList", String.class, Object.class,
            int.class, int.class);
    verifier.verifyTrace(event("IBATIS", queryForList1, Expectations.cachedArgs(queryForListId)));
    verifier.verifyTrace(event("IBATIS", queryForList2, Expectations.cachedArgs(queryForListId)));
    verifier.verifyTrace(event("IBATIS", queryForList3, Expectations.cachedArgs(queryForListId)));
    verifier.verifyTrace(event("IBATIS", queryForList4, Expectations.cachedArgs(queryForListId)));
}
 
开发者ID:naver,项目名称:pinpoint,代码行数:20,代码来源:SqlMapExecutorTestBase.java


示例7: testExecutePrefixMethodsOnCobarSqlMapClientTemplate

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
/**
 * since {@link CobarSqlMapClientTemplate#execute(SqlMapClientCallback)},
 * {@link CobarSqlMapClientTemplate#executeWithListResult(SqlMapClientCallback)
 * )} and
 * {@link CobarSqlMapClientTemplate#executeWithMapResult(SqlMapClientCallback)
 * )} don't support partitioning behaviors, we can unit test them together
 * and use one of them as their representation.
 */
public void testExecutePrefixMethodsOnCobarSqlMapClientTemplate() {

    getSqlMapClientTemplate().execute(new SqlMapClientCallback() {
        public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
            Follower f = new Follower("fname");
            return executor.insert("com.alibaba.cobar.client.entities.Follower.create", f);
        }
    });

    String confirmSQL = "select name from followers where name='fname'";
    // execute method doesn't support partitioning behavior, so the entity will be inserted into default data source, that's , partition1, not partition2 as the rules state.
    verifyEntityExistenceOnSpecificDataSource(confirmSQL, jt1m);
    verifyEntityNonExistenceOnSpecificDataSource(confirmSQL, jt1s);
    verifyEntityNonExistenceOnSpecificDataSource(confirmSQL, jt2m);
    verifyEntityNonExistenceOnSpecificDataSource(confirmSQL, jt2s);
}
 
开发者ID:alibaba,项目名称:cobarclient,代码行数:25,代码来源:CobarSqlMapClientTemplateWithNamespaceRouterTest.java


示例8: batchInsert

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
/**
 * 엑셀서비스의 배치업로드를 실행한다.
 * @param queryId
 *        <code>String</code>
 * @param list
 *        <code>List&lt;Object&gt;</code>
 * @return
 */
public Integer batchInsert(final String queryId, final List<Object> list) {
    return (Integer) getSqlMapClientTemplate().execute(
        new SqlMapClientCallback() {

            public Object doInSqlMapClient(SqlMapExecutor executor)
                    throws SQLException {

                executor.startBatch();

                for (Iterator<Object> itr = list.iterator(); itr.hasNext();) {
                    executor.insert(queryId, itr.next());
                }

                return executor.executeBatch();
            }
        });
}
 
开发者ID:eGovFrame,项目名称:egovframework.rte.root,代码行数:26,代码来源:EgovExcelServiceDAO.java


示例9: batchInsertEmp

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public Integer batchInsertEmp(final String queryId, final List<EmpVO> list) {
    return (Integer) getSqlMapClientTemplate().execute(
        new SqlMapClientCallback() {
            public Object doInSqlMapClient(SqlMapExecutor executor)
                    throws SQLException {
                Iterator<EmpVO> itr = list.iterator();

                executor.startBatch();
                while (itr.hasNext()) {
                    executor.insert(queryId, itr.next());
                }
                // autoboxing
                return executor.executeBatch();
            }
        });

}
 
开发者ID:eGovFrame,项目名称:egovframework.rte.root,代码行数:18,代码来源:EmpDAO.java


示例10: queryForList

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
public List queryForList(final String statementName, final Object parameterObject, String dataSource){
    return sqlMapClientTemplate.execute(new SqlMapClientCallback<List>() {

        public List doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
            return executor.queryForList(statementName, parameterObject);
        }
    });
}
 
开发者ID:shuqin,项目名称:ALLIN,代码行数:10,代码来源:SqlMapClientTemplateSupport.java


示例11: queryForObject

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public Object queryForObject(final String statementName, final Object parameterObject)
		throws DataAccessException {

	return execute(new SqlMapClientCallback<Object>() {
		public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			return executor.queryForObject(statementName, parameterObject);
		}
	});
}
 
开发者ID:otsecbsol,项目名称:linkbinder,代码行数:10,代码来源:SqlMapClientTemplate.java


示例12: queryForList

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public List queryForList(final String statementName, final Object parameterObject)
		throws DataAccessException {

	return execute(new SqlMapClientCallback<List>() {
		public List doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			return executor.queryForList(statementName, parameterObject);
		}
	});
}
 
开发者ID:otsecbsol,项目名称:linkbinder,代码行数:10,代码来源:SqlMapClientTemplate.java


示例13: queryWithRowHandler

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public void queryWithRowHandler(
		final String statementName, final Object parameterObject, final RowHandler rowHandler)
		throws DataAccessException {

	execute(new SqlMapClientCallback<Object>() {
		public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			executor.queryWithRowHandler(statementName, parameterObject, rowHandler);
			return null;
		}
	});
}
 
开发者ID:otsecbsol,项目名称:linkbinder,代码行数:12,代码来源:SqlMapClientTemplate.java


示例14: queryForMap

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public Map queryForMap(
		final String statementName, final Object parameterObject, final String keyProperty)
		throws DataAccessException {

	return execute(new SqlMapClientCallback<Map>() {
		public Map doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			return executor.queryForMap(statementName, parameterObject, keyProperty);
		}
	});
}
 
开发者ID:otsecbsol,项目名称:linkbinder,代码行数:11,代码来源:SqlMapClientTemplate.java


示例15: insert

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public Object insert(final String statementName, final Object parameterObject)
		throws DataAccessException {

	return execute(new SqlMapClientCallback<Object>() {
		public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			return executor.insert(statementName, parameterObject);
		}
	});
}
 
开发者ID:otsecbsol,项目名称:linkbinder,代码行数:10,代码来源:SqlMapClientTemplate.java


示例16: update

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public int update(final String statementName, final Object parameterObject)
		throws DataAccessException {

	return execute(new SqlMapClientCallback<Integer>() {
		public Integer doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			return executor.update(statementName, parameterObject);
		}
	});
}
 
开发者ID:otsecbsol,项目名称:linkbinder,代码行数:10,代码来源:SqlMapClientTemplate.java


示例17: delete

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
public int delete(final String statementName, final Object parameterObject)
		throws DataAccessException {

	return execute(new SqlMapClientCallback<Integer>() {
		public Integer doInSqlMapClient(SqlMapExecutor executor) throws SQLException {
			return executor.delete(statementName, parameterObject);
		}
	});
}
 
开发者ID:otsecbsol,项目名称:linkbinder,代码行数:10,代码来源:SqlMapClientTemplate.java


示例18: testSqlMapClientTemplate

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
@Test
public void testSqlMapClientTemplate() throws SQLException {
	DataSource ds = mock(DataSource.class);
	Connection con = mock(Connection.class);
	final SqlMapSession session = mock(SqlMapSession.class);
	SqlMapClient client = mock(SqlMapClient.class);

	given(ds.getConnection()).willReturn(con);
	given(client.openSession()).willReturn(session);

	SqlMapClientTemplate template = new SqlMapClientTemplate();
	template.setDataSource(ds);
	template.setSqlMapClient(client);
	template.afterPropertiesSet();
	Object result = template.execute(new SqlMapClientCallback() {
		@Override
		public Object doInSqlMapClient(SqlMapExecutor executor) {
			assertTrue(executor == session);
			return "done";
		}
	});
	assertEquals("done", result);

	verify(con).close();
	verify(session).setUserConnection(con);
	verify(session).close();
}
 
开发者ID:deathspeeder,项目名称:class-guard,代码行数:28,代码来源:SqlMapClientTests.java


示例19: testAndVerifyQueryForMap

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
protected final void testAndVerifyQueryForMap(SqlMapExecutor executor) throws Exception {
    final String queryForMapId = "queryForMapId";
    executor.queryForMap(queryForMapId, new Object(), "key");
    executor.queryForMap(queryForMapId, new Object(), "key", "value");

    PluginTestVerifier verifier = PluginTestVerifierHolder.getInstance();
    Method queryForMap1 = executor.getClass().getDeclaredMethod("queryForMap", String.class, Object.class,
            String.class);
    Method queryForMap2 = executor.getClass().getDeclaredMethod("queryForMap", String.class, Object.class,
            String.class, String.class);
    verifier.verifyTrace(event("IBATIS", queryForMap1, Expectations.cachedArgs(queryForMapId)));
    verifier.verifyTrace(event("IBATIS", queryForMap2, Expectations.cachedArgs(queryForMapId)));
}
 
开发者ID:naver,项目名称:pinpoint,代码行数:14,代码来源:SqlMapExecutorTestBase.java


示例20: testAndVerifyQueryForObject

import com.ibatis.sqlmap.client.SqlMapExecutor; //导入依赖的package包/类
protected final void testAndVerifyQueryForObject(SqlMapExecutor executor) throws Exception {
    final String queryForObjectId = "queryForObjectId";
    executor.queryForObject(queryForObjectId);
    executor.queryForObject(queryForObjectId, new Object());
    executor.queryForObject(queryForObjectId, new Object(), new Object());

    PluginTestVerifier verifier = PluginTestVerifierHolder.getInstance();
    Method queryForObject1 = executor.getClass().getDeclaredMethod("queryForObject", String.class);
    Method queryForObject2 = executor.getClass().getDeclaredMethod("queryForObject", String.class, Object.class);
    Method queryForObject3 = executor.getClass().getDeclaredMethod("queryForObject", String.class, Object.class,
            Object.class);
    verifier.verifyTrace(event("IBATIS", queryForObject1, Expectations.cachedArgs(queryForObjectId)));
    verifier.verifyTrace(event("IBATIS", queryForObject2, Expectations.cachedArgs(queryForObjectId)));
    verifier.verifyTrace(event("IBATIS", queryForObject3, Expectations.cachedArgs(queryForObjectId)));
}
 
开发者ID:naver,项目名称:pinpoint,代码行数:16,代码来源:SqlMapExecutorTestBase.java



注:本文中的com.ibatis.sqlmap.client.SqlMapExecutor类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ArrayIndex类代码示例发布时间:2022-05-22
下一篇:
Java CompletionContext类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap