kettle使用文件导入到Postgresql出现如下几种问题的总结

1、kettle使用文件导入到Postgresql出现如下几种问题的总结:

 kettle使用文件导入到Postgresql出现如下几种问题的总结:
、第一种错误,报错如ERROR: extra data after last expected column所示。或者报错为报错为0x05,多一列,extra data after last expected column。
)、sql查询语句定位到某个字段:
SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(),'%')
)、解决方法,使用空替代,原因是出现特殊字符,char(),这种字符,导致的错误。
解决方法如下所示:
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
Object[] r = getRow(); if (r == null) {
setOutputDone();
return false;
} // It is always safest to call createOutputRow() to ensure that your output row’s Object[] is large
// enough to handle any new fields you are creating in this step.
r = createOutputRow(r, data.outputRowMeta.size()); String 字段名称 = get(Fields.In, "字段名称").getString(r);
if(字段名称 != null) {
字段名称 = 字段名称.replaceAll((char) + "", "");
}
get(Fields.Out, "字段名称").setValue(r, 字段名称); // Send the row on to the next step.
putRow(data.outputRowMeta, r); return true;
} 、第二种错误,报错如missing data for column "datastamp"。
)、sql查询语句定位到某个字段:
SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(),'%')
或者
SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(),'%')
)、解决方法:是字段的值出现了,换行回车,char(),char()。char()多一行,少n列,missing data column xxx。解决方法,使用字符替代,然后再替换回来。
解决方法如下所示:
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
Object[] r = getRow(); if (r == null) {
setOutputDone();
return false;
} // It is always safest to call createOutputRow() to ensure that your output row’s Object[] is large
// enough to handle any new fields you are creating in this step.
r = createOutputRow(r, data.outputRowMeta.size()); String 字段名称 = get(Fields.In, "字段名称").getString(r);
if(字段名称 != null) {
字段名称 = 字段名称.replaceAll("\\r", "@#r;");
字段名称 = 字段名称.replaceAll("\\n", "@#n;");
}
get(Fields.Out, "字段名称").setValue(r, 字段名称); // Send the row on to the next step.
putRow(data.outputRowMeta, r); return true;
} 、第三种错误,报错如,0x00的解决方法:
)、sql查询语句定位到某个字段:
SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(),'%')
)、解决方法1
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {
Object[] r = getRow(); if (r == null) {
setOutputDone();
return false;
} // It is always safest to call createOutputRow() to ensure that your output row’s Object[] is large
// enough to handle any new fields you are creating in this step.
r = createOutputRow(r, data.outputRowMeta.size()); // Get the value from an input field
String 字段名称 = get(Fields.In, "字段名称").getString(r); if(字段名称 != null) {
字段名称= 字段名称.replaceAll("\\u0000", "");
} get(Fields.Out, "字段名称").setValue(r, 字段名称); // Send the row on to the next step.
putRow(data.outputRowMeta, r); return true;
}

待续......

上一篇:iOS开发之Socket通信实战--Request请求数据包编码模块


下一篇:关于WEB Service&WCF&WebApi实现身份验证之WCF篇(2)