java irowset行数,Java CloneableRecord.put方法代码示例
import com.taobao.tddl.executor.record.CloneableRecord; //导入方法依赖的package包/类
@SuppressWarnings("rawtypes")
@Override
protected int executePut(ExecutionContext executionContext, IPut put, ITable table, IndexMeta meta)
throws Exception {
ITransaction transaction = executionContext.getTransaction();
int affect_rows = 0;
IPut delete = put;
ISchematicCursor conditionCursor = null;
IRowSet rowSet = null;
CloneableRecord key = CodecFactory.getInstance(CodecFactory.FIXED_LENGTH)
.getCodec(meta.getKeyColumns())
.newEmptyRecord();
try {
conditionCursor = ExecutorContext.getContext()
.getTopologyExecutor()
.execByExecPlanNode(delete.getQueryTree(), executionContext);
while ((rowSet = conditionCursor.next()) != null) {
affect_rows++;
for (ColumnMeta cm : meta.getKeyColumns()) {
Object val = getValByColumnMeta(rowSet, cm);
key.put(cm.getName(), val);
}
// CloneableRecord key =
// ExecUtils.convertToClonableRecord(rowSet);
prepare(transaction, table, rowSet, null, null, PUT_TYPE.DELETE);
table.delete(executionContext, key, meta, put.getTableName());
}
} catch (Exception e) {
throw e;
} finally {
if (conditionCursor != null) {
List exs = new ArrayList();
exs = conditionCursor.close(exs);
if (!exs.isEmpty()) {
throw GeneralUtil.mergeException(exs);
}
}
}
return affect_rows;
}
java irowset行数,Java CloneableRecord.put方法代码示例相关推荐
- java.util.zip 用法,Java压缩文件工具类ZipUtil使用方法代码示例
本文实例通过Java的Zip输入输出流实现压缩和解压文件,前一部分代码实现获取文件路径,压缩文件名的更改等,具体如下: package com.utility.zip; import java.io. ...
- JAVA里tokens意思_Java TokenMetadata.sortedTokens方法代码示例
import org.apache.cassandra.locator.TokenMetadata; //导入方法依赖的package包/类 /** * Get the "primary r ...
- java中isolate时间_Java HikariDataSource.setIdleTimeout方法代码示例
import com.zaxxer.hikari.HikariDataSource; //导入方法依赖的package包/类 private HikariDataSource createHikari ...
- java getattribute为空_Java TransMeta.getAttribute方法代码示例
import org.pentaho.di.trans.TransMeta; //导入方法依赖的package包/类 @Override public void getData( TransMeta ...
- java接收rowtype类型_Java PhysType.getJavaRowType方法代码示例
import org.apache.calcite.adapter.enumerable.PhysType; //导入方法依赖的package包/类 public Result implementSp ...
- Java程序中fix time_Java Position.setFixTime方法代码示例
import org.traccar.model.Position; //导入方法依赖的package包/类 @Override protected Object decode( Channel ch ...
- java okhttp设置超时_Java OkHttpClient.setWriteTimeout方法代码示例
import com.squareup.okhttp.OkHttpClient; //导入方法依赖的package包/类 @Bean @ConditionalOnMissingBean public ...
- java jtree 监听_Java JTree.addTreeExpansionListener方法代码示例
import javax.swing.JTree; //导入方法依赖的package包/类 public PackageBrowser(JFrame frame, String title, bool ...
- java打印设置缩放_Java PrintSetup.setPaperSize方法代码示例
import org.apache.poi.ss.usermodel.PrintSetup; //导入方法依赖的package包/类 /** * 复制模板工作表的打印区域到数据工作表中 * * @au ...
最新文章
- C++关键字积累——持续更新
- 二叉树最近公共祖先节点
- Spring Boot中的Properties
- python中goto的用法_python3里用goto
- python getopt.getopt_python 参数格式化getopt
- leetcode 387 C++数组做法
- visual报表服务器项目,为 Visual Studio ALM 创建报表服务器项目
- 西瓜书+实战+吴恩达机器学习（十八）降维（主成分分析 PCA）
- interpolation algorithm
- echarts地图（中国地图展示各省数据）
- 安科瑞综合能效管理系统在数据中心的应用
- 菠萝V1mini是以太坊唯一的静音机器
- IPsec-Tools配置之racoon
- 【一文学会】vue.js入门到放弃
- 招聘简历管理系统的简单设计
- QT开发调用FDTI ftd2xx.dll库
- vue数据更新，页面不更新
- phoenix启动 Unable to load native-hadoop library for your platform... using builtin-java classes wher
- js上传图片 识别条形码
- TCP/IP协议专栏——以太帧结构 详解——网络入门和工程维护必看