kettle使用文件導入到Postgresql出現如下幾種問題的總結

1、kettle使用文件導入到Postgresql出現如下幾種問題的總結：

kettle使用文件導入到Postgresql出現如下幾種問題的總結：
1、第一種錯誤，報錯如ERROR:  extra data after last expected column所示。或者報錯為報錯為0x05,多一列,extra data after last expected column。
1）、sql查詢語句定位到某個字段：
    SELECT * from 數據表名稱 where 字段名稱 like CONCAT('%',char(5),'%')
2）、解決方法，使用空替代，原因是出現特殊字符，char(5)，這種字符，導致的錯誤。
解決方法如下所示：
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)5 + "", "");
    }
    get(Fields.Out, "字段名稱").setValue(r, 字段名稱);

    // Send the row on to the next step. 
    putRow(data.outputRowMeta, r);

    return true; 
} 

2、第二種錯誤，報錯如missing data for column "datastamp"。
1）、sql查詢語句定位到某個字段：
    SELECT * from 數據表名稱 where 字段名稱 like CONCAT('%',char(10),'%')
    或者
    SELECT * from 數據表名稱 where 字段名稱 like CONCAT('%',char(13),'%')
2）、解決方法：是字段的值出現了，換行回車,char(10),char(13)。char(10)多一行,少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; 
} 

3、第三種錯誤，報錯如，0x00的解決方法：
1）、sql查詢語句定位到某個字段：
    SELECT * from 數據表名稱 where 字段名稱 like CONCAT('%',char(0),'%')
2）、解決方法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; 
} 
        

 

待續......