JavaDBF.jar其实很早都不再更新了,在日新月异的科技圈算得上远古上神的jar包,早该身归混沌了。
但我们的项目要用到,因为之前做的大宗期货交易行情的分析文件依然是dbf文件,没有办法,还得用
JavaDBF库把行情实时数据保存到DBF文件中。
第一步,新建DBFManager类
public class DBFManager { private static Logger logger = Logger.getLogger(DBFManager.class); // 构造一个单线程service,保证调用dbf写入的方法不阻塞 private static ExecutorService pool = Executors.newSingleThreadExecutor(); public static void startDbf(List<Quotation> allQuotation) { try { if (Variables.openDBF) { logger.info("写入DBF数据库开始"); long dt1 = System.currentTimeMillis(); // 执行线程 pool.execute(new Thread(new DBFThread(allQuotation))); logger.info("写入DBF数据库结束"); long dt2 = System.currentTimeMillis(); logger.info("读取行情和写入DBF花费时间:(" + (dt2 - dt1) + ")"); } } catch (Exception e) { logger.error("dbf写入错误"); } } }
在行情推送过来的地方调用
DBFManager.startDbf(quotations);
第二步,新建DBF线程类
public class DBFThread implements Runnable { private List<Quotation> quotations; /** * 传递构造方法. * * @param quotations */ public DBFThread(List<Quotation> quotations) { this.quotations = quotations; } @Override public void run() { // 将行情信息写入到dbf文件中 DBFOperation.writeDBFByQuotation(Variables.path_info_dbf, quotations); } }
第三步,新建DBF操作类
public class DBFOperation { private static Logger logger = Logger.getLogger(DBFOperation.class); /** * 删除文件内容. */ public static void deleteQuotation(String path) { File myDelFile = new File(path); if (myDelFile.exists()) { myDelFile.delete(); } } /** * 将行情信息添加到文件中 * * @param path * @param quotaionList * @throws IOException */ public static void writeDBFByQuotation(String path, List<Quotation> quotaionList) { FileOutputStream fos = null; try { DBFField fields[] = new DBFField[30]; // S1 HQZQDM 证券代码 Char 6 fields[0] = new DBFField(); fields[0].setName("S1"); fields[0].setDataType(DBFField.FIELD_TYPE_C); fields[0].setFieldLength(6); // S2 HQZQJC 证券名称 Char 8 fields[1] = new DBFField(); fields[1].setName("S2"); fields[1].setDataType(DBFField.FIELD_TYPE_C); fields[1].setFieldLength(80); // S3 HQZRSP 前收盘价格 Num 8 3 fields[2] = new DBFField(); fields[2].setName("S3"); fields[2].setDataType(DBFField.FIELD_TYPE_N); fields[2].setFieldLength(8); fields[2].setDecimalCount(3); // S4 HQJRKP 今开盘价格 Num 8 3 fields[3] = new DBFField(); fields[3].setName("S4"); fields[3].setDataType(DBFField.FIELD_TYPE_N); fields[3].setFieldLength(8); fields[3].setDecimalCount(3); Object[] obj1 = new Object[4]; obj1[0] = "000000"; obj1[1] = ""; for (int i = 2; i < obj1.length; i++) { obj1[i] = Double.parseDouble("0"); } // 定义DBFWriter实例用来写DBF文件 DBFWriter writer = new DBFWriter(); // 字符编码设置为GB2312,防止中文乱码 writer.setCharactersetName("GB2312"); writer.setFields(fields); // 添加纪录,此时未写入到dbf文件,而是在内容中 writer.addRecord(obj1); // Object[] objs = new Object[30]; for (Quotation quotation : quotaionList) { Object[] obj = new Object[4]; // 证卷代码 obj[0] = quotation.getScode(); // 证卷名称 // 中文乱码解决方法 Pattern pWord = Pattern.compile("[\u4e00-\u9fa5]");// 校验中文的正则表达式 String value = quotation.getSname(); String blank = ""; if (pWord.matcher(value).find()) {// 如果包含中文就要补够2倍中文字数个空格,否则会导致中文乱码 for (int j = 0; j < value.getBytes().length; j++) { blank += " "; } } obj[1] = value + blank; // 前收盘价 obj[2] = quotation.getLastPrice().doubleValue(); // 今开盘价 obj[3] = quotation.getOpen().doubleValue(); writer.addRecord(obj); } fos = new FileOutputStream(path); writer.write(fos); } catch (IOException e) { logger.error("写入DBF出错了" + e.getMessage()); } finally { try { fos.close(); } catch (IOException e) { logger.error("输出流关闭出错" + e.getMessage()); } } } }
写的操作我已经提供了,但我一直没有找到dbf文件的更新操作,也就是说,假如已存在一行数据,但第二次数据过来时,只需要更新一列,这时候该如何做呢?