本文整理汇总了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<Object></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;未经允许,请勿转载。 |
请发表评论