将数据以二进制流方式写入数据并再还原成原来的文件，编辑再写入
数据重发功能需要进行人工干预，操作数据为二进制流和结构化数据之间的相互转换，并确保相互转换过程编码格式统一：
一、需求：
将结构化数据以二进制格式保存在数据库中（别说这样不好，别说建议文件保存在文件夹下，数据库保存文件路径，我也懂的，但这里需求只能是这样来做的。数据对接懂的。）
所实现的代码(以对象方式)：
/**
* 将对象插入前置机数据库中<p>
* @param exData 要插入的数据
* @param xmlFileName xml文件路径
* @param index 自增长主键
* @throws Exception
*/
public void insert2zwdt(ExData exData, String xmlFileName, Long index) throws Exception{
//================================
Connection conn = getConnection();
conn.setAutoCommit(false); // 设置手动提交
PreparedStatement pstmt=null;
File file=new File(xmlFileName);
InputStream in = new FileInputStream(file);
String sql="insert into exdata_sending(NM_SEQ_ID,ST_SOURCE,ST_KEY,ST_VERSION,ST_VALUE,ST_OP,ST_MEMO,BL_DATA,ST_DEST) "
+ "values(?,?,?,?,?,?,?,?,?)";
pstmt=conn.prepareStatement(sql);
pstmt.setInt(1, index.intValue());
pstmt.setString(2, exData.getStSource());
pstmt.setString(3, exData.getStKey());
pstmt.setString(4, exData.getStVersion());
pstmt.setString(5, exData.getStValue());
pstmt.setString(6, exData.getStOp());
pstmt.setString(7, exData.getStMemo());
pstmt.setBinaryStream(8, in, file.length());
pstmt.setString(9, exData.getStDest());
pstmt.execute();
conn.commit();
pstmt.close();
}
二、需求：
数据对账过程出现错误，需要进行人工干涉。
步骤：1.找出前置机上的错误数据，并标记出对应自己库中的那条数据。
2.以流方式在本地还原成文件。
3.将文件再编辑器中编辑后形成新的本地文件，同时保存最新并正确的数据在本地及前置机库和自己系统库中。
4.修改状态。
核心实现代码（往本系统库中插数据）：
/**
* 往XXXX中插入数据.
* @param exData 要插入的数据
* @param xmlFileName xml文件路径
* @throws SQLException
* @throws FileNotFoundException
*/
public void insert2own(ExData exData, String xmlFileName, Long index) throws Exception{
File file=new File(xmlFileName);
InputStream in = new FileInputStream(file);
DataSending dataSending = new DataSending();
dataSending.setNmSeqId(index.intValue());
dataSending.setStSource(exData.getStSource());
dataSending.setStKey(exData.getStKey());
dataSending.setStVersion(exData.getStVersion());
dataSending.setStValue(exData.getStValue());
dataSending.setStOp(exData.getStOp());
dataSending.setStMemo(exData.getStMemo());
dataSending.setSendDate(new Date());
byte[] data=new byte[]{};
data=inputStreamToByte(in);
dataSending.setBlData(data);
dataSending.setStDest(exData.getStDest());
dataSendingDao.save(dataSending);
}
/**
* 将文件保存到字节数组中.
* @param in 输入流
* @return
* @throws IOException
*/
private byte[] inputStreamToByte(InputStream in) throws IOException{
ByteArrayOutputStream baos=new ByteArrayOutputStream();
int ch;
while((ch=in.read())!=-1){
baos.write(ch);
}
byte[] data=baos.toByteArray();
baos.close();
return data;
}
需要总结的地方还是拿出部分内容来总结一下，也更新一下自己的代码库。