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

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

 1 kettle使用文件导入到Postgresql出现以下几种问题的总结:  2 1、第一种错误,报错如ERROR: extra data after last expected column所示。或者报错为报错为0x05,多一列,extra data after last expected column。  3 1)、sql查询语句定位到某个字段:  4     SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(5),'%')  5 2)、解决方法,使用空替代,缘由是出现特殊字符,char(5),这种字符,致使的错误。  6 解决方法以下所示:  7 public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {  8     Object[] r = getRow();  9 
10     if (r == null) { 11  setOutputDone(); 12     return false; 13  } 14 
15     // It is always safest to call createOutputRow() to ensure that your output row’s Object[] is large 16     // enough to handle any new fields you are creating in this step. 
17     r = createOutputRow(r, data.outputRowMeta.size()); 18 
19     String 字段名称 = get(Fields.In, "字段名称").getString(r); 20     if(字段名称 != null) { 21         字段名称 = 字段名称.replaceAll((char)5 + "", ""); 22  } 23     get(Fields.Out, "字段名称").setValue(r, 字段名称); 24 
25     // Send the row on to the next step. 
26  putRow(data.outputRowMeta, r); 27 
28     return true; 29 } 30 
31 2、第二种错误,报错如missing data for column "datastamp"32 1)、sql查询语句定位到某个字段: 33     SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(10),'%') 34  或者 35     SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(13),'%') 36 2)、解决方法:是字段的值出现了,换行回车,char(10),char(13)。char(10)多一行,少n列,missing data column xxx。解决方法,使用字符替代,而后再替换回来。 37 解决方法以下所示: 38 public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException { 39     Object[] r = getRow(); 40 
41     if (r == null) { 42  setOutputDone(); 43     return false; 44  } 45 
46     // It is always safest to call createOutputRow() to ensure that your output row’s Object[] is large 47     // enough to handle any new fields you are creating in this step. 
48     r = createOutputRow(r, data.outputRowMeta.size()); 49 
50     String 字段名称 = get(Fields.In, "字段名称").getString(r); 51     if(字段名称 != null) { 52         字段名称 = 字段名称.replaceAll("\\r", "@#r;"); 53         字段名称 = 字段名称.replaceAll("\\n", "@#n;"); 54  } 55     get(Fields.Out, "字段名称").setValue(r, 字段名称); 56     
57     // Send the row on to the next step. 
58  putRow(data.outputRowMeta, r); 59 
60     return true; 61 } 62 
63 3、第三种错误,报错如,0x00的解决方法: 64 1)、sql查询语句定位到某个字段: 65     SELECT * from 数据表名称 where 字段名称 like CONCAT('%',char(0),'%') 66 2)、解决方法1 67 public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException { 68     Object[] r = getRow(); 69 
70     if (r == null) { 71  setOutputDone(); 72     return false; 73  } 74 
75     // It is always safest to call createOutputRow() to ensure that your output row’s Object[] is large 76     // enough to handle any new fields you are creating in this step. 
77     r = createOutputRow(r, data.outputRowMeta.size()); 78 
79     // Get the value from an input field 
80     String 字段名称 = get(Fields.In, "字段名称").getString(r); 81 
82     if(字段名称 != null) { 83         字段名称= 字段名称.replaceAll("\\u0000", ""); 84  } 85 
86     get(Fields.Out, "字段名称").setValue(r, 字段名称); 87 
88     // Send the row on to the next step. 
89  putRow(data.outputRowMeta, r); 90 
91     return true; 92 } 93

 

待续......this

相关文章
相关标签/搜索