package com.walker.di;
|
|
import com.walker.infrastructure.utils.KeyValue;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
public abstract class AbstractErrorWriter implements ErrorWriter{
|
|
protected final transient Logger logger = LoggerFactory.getLogger(getClass());
|
|
// @Override
|
// public void write(Map<String, String> data) {
|
//
|
// }
|
//
|
// @Override
|
// public void close() {
|
//
|
// }
|
|
protected String[] cloneColumns(List<String> fieldNames){
|
String[] columns = new String[fieldNames.size()+1];
|
for(int i=0; i< fieldNames.size(); i++){
|
columns[i] = fieldNames.get(i);
|
}
|
// 增加一列: 错误原因
|
columns[fieldNames.size()] = Constants.ERROR_COLUMN_NAME;
|
return columns;
|
}
|
|
/**
|
* 把一行数据(使用 KeyValue 对象表示)转换成普通 Map
|
* @param data
|
* @return
|
* @date 2023-02-08
|
*/
|
protected Map<String, String> toMap(List<KeyValue<String, String>> data){
|
// 数据转 Map
|
Map<String, String> map = new HashMap<>();
|
for(KeyValue<String, String> kv : data){
|
map.put(kv.getKey(), kv.getValue());
|
}
|
return map;
|
}
|
}
|
