java 读取 dbf数据库的dbf文件代码

                                                                                          java 读取 dbf数据库的dbf文件代码

 

package cai.fu.com;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.InputStream;

import java.io.OutputStream;

import java.math.BigDecimal;

import java.util.HashMap;

import java.util.Map;

import com.linuxense.javadbf.DBFField;

import com.linuxense.javadbf.DBFReader;

import com.linuxense.javadbf.DBFWriter;

import net.sf.json.JSONObject;

import redis.clients.jedis.Jedis;

public class Rwdbf {

 private static Jedis jedis;

 public static void setup() {

  // 连接redis服务器，192.168.0.188:6379

  jedis = new Jedis("192.168.0.188", 6379);

  // 权限认证

  // jedis.auth("sa123456");

 }

 public static void readDBF(String path)

 {

  InputStream fis = null;

  Map map = new HashMap();

  try {

   // 读取文件的输入流

   fis = new FileInputStream(path);

   // 根据输入流初始化一个DBFReader实例，用来读取DBF文件信息

   DBFReader reader = new DBFReader(fis);

   // 调用DBFReader对实例方法得到path文件中字段的个数

   int fieldsCount = reader.getFieldCount();

   Object[] rowValues;

   // 一条条取出path文件中记录

   while ((rowValues = reader.nextRecord()) != null) {

    for (int i = 0; i < rowValues.length; i++) {

     if (i == 0) {

      // 0.股票代码

      map.put("symbol", rowValues[i].toString());

     } else if (i == 2) {

      String cloPrices = rowValues[i].toString();

      double topPrices = Double.parseDouble(cloPrices) * 1.1;

      double fallPrices = Double.parseDouble(cloPrices) * 0.90;

      double pricetop = topPrices - 9;

      double pricefall = fallPrices - 9;

      BigDecimal bfall = new BigDecimal(pricefall);

      double pricefa = bfall.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();

      BigDecimal btop = new BigDecimal(pricetop);

      double priceto = btop.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();

      // 7.跌停价

      map.put("pricefall", pricefa);

      // 6.涨停价

      map.put("pricetop", pricetop);

      BigDecimal bdto = new BigDecimal(Double.parseDouble(rowValues[i].toString()));

      double pricebdto = bdto.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();

      // 3.收盘价

      map.put("close", pricebdto);

     } else if (i == 3) {

      // 2.今开

      map.put("open", rowValues[i].toString());

     } else if (i == 4) {

      // 1.现价

      map.put("currentPrice", rowValues[i].toString());

     } else if (i == 5) {

      // 9.成交数量

      map.put("amount", new BigDecimal(rowValues[i].toString()).toPlainString());

     } else if (i == 8) {

      BigDecimal hqzgcj = new BigDecimal(rowValues[i].toString());

      double pricehqzgcj = hqzgcj.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();

      // 4.最高价

      map.put("high", pricehqzgcj);

     } else if (i == 9) {

      BigDecimal hazdcj = new BigDecimal(rowValues[i].toString());

      double priceHazdcj = hazdcj.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();

      // 5.最低价

      map.put("low", priceHazdcj);

     } else if (i == 15) {

      // HQSJW5：行情Sell价位5

      // HQSSL5：行情Buy数量5

      map.put("HQSJW5", rowValues[i].toString());

     } else if (i == 16) {

      map.put("HQSSL5", rowValues[i].toString());

     } else if (i == 17) {

      map.put("HQSJW4", rowValues[i].toString());

     } else if (i == 18) {

      map.put("HQSSL4", rowValues[i].toString());

     } else if (i == 19) {

      map.put("HQSJW3", rowValues[i].toString());

     } else if (i == 20) {

      map.put("HQSSL3", rowValues[i].toString());

     } else if (i == 21) {

      map.put("HQSJW2", rowValues[i].toString());

     } else if (i == 22) {

      map.put("HQSSL2", rowValues[i].toString());

     } else if (i == 23) {

      map.put("HQSJW1", rowValues[i].toString());

     } else if (i == 24) {

      map.put("HQSSL1", rowValues[i].toString());

     } else if (i == 25) {

      map.put("HQBJW1", rowValues[i].toString());

     } else if (i == 26) {

      map.put("HQBSL1", rowValues[i].toString());

     } else if (i == 27) {

      map.put("HQBJW2", rowValues[i].toString());

     } else if (i == 28) {

      map.put("HQBSL2", rowValues[i].toString());

     } else if (i == 29) {

      map.put("HQBJW3", rowValues[i].toString());

     } else if (i == 30) {

      map.put("HQBSL3", rowValues[i].toString());

     } else if (i == 31) {

      map.put("HQBJW4", rowValues[i].toString());

     } else if (i == 32) {

      map.put("HQBSL4", rowValues[i].toString());

     } else if (i == 33) {

      map.put("HQBJW5", rowValues[i].toString());

     } else if (i == 34) {

      map.put("HQBSL5", rowValues[i].toString());

     }

     // 8.换手率

     map.put("change", "");

    }

    JSONObject jsonObject = JSONObject.fromObject(map);

    jedis.set("5_" + jsonObject.get("symbol"), jsonObject.toString());

   }

  } catch (Exception e) {

   e.printStackTrace();

  } finally {

   try {

    fis.close();

   } catch (Exception e) {

   }

  }

 }

 public static void main(String[] args) {

  Rwdbf rdbf = new Rwdbf();

  String path = "E:\\SJSHQ.DBF";

  setup();

  rdbf.readDBF(path);

 }

}