BerkeleyDB使用SecondKey给数据排序的实现方法

Berkeley DB使用SecondKey给数据排序的实现方法是本文我们主要要介绍的内容，在做项目的时候用到了nosql数据库BDB，借此机会研究了一下它的用法。它的官方示例和文档比较丰富，感觉比较容易学习。在开发过程中出现了一个需求，要把数据根据插入时间遍历，个人认为通过第二主键（SecondKey）比较容易实现。

以下是我的基本实现过程：

1.在ValueBean中加入insertTime属性

 
 
 
  
  
  public class ValueBean{    
  
  
  private String insertTime;    
  
  
  private String hostName;    
  
  
  private byte[] value;    
  
  
  public String getHostName() {    
  
  
  return hostName;    
  
  
  }    
  
  
  public void setHostName(String hostName) {    
  
  
  this.hostName = hostName;    
  
  
  }    
  
  
  public String getInsertTime() {    
  
  
  return insertTime;    
  
  
  }    
  
  
  public void setInsertTime(String insertTime) {    
  
  
  this.insertTime = insertTime;    
  
  
  }    
  
  
  public byte[] getValue() {    
  
  
  return value;    
  
  
  }    
  
  
  public void setValue(byte[] value) {    
  
  
  this.value = value;    
  
  
  }    
  
  
  }

其中的hostName属性在主从同步和生成插入时间时用到，value属性就是key-value中的值

2.TupleBinding类

 
 
 
  
  
  public class ValueBeanBinding extends TupleBinding {    
  
  
  @Override    
  
  
  public ValueBean entryToObject(TupleInput input) {    
  
  
  String time = input.readString();    
  
  
  String name = input.readString();    
  
  
  byte[] value = new byte[input.getBufferLength()-input.getBufferOffset()];//获得value长度     
  
  
  input.read(value);    
  
  
  ValueBean data = new ValueBean();    
  
  
  data.setInsertTime(time);    
  
  
  data.setHostName(name);    
  
  
  data.setValue(value);    
  
  
  return data;    
  
  
  }    
  
  
  @Override    
  
  
  public void objectToEntry(ValueBean object, TupleOutput output) {    
  
  
  ValueBean value = object;    
  
  
  output.writeString(value.getInsertTime());    
  
  
  output.writeString(value.getHostName());    
  
  
  output.write(value.getValue());    
  
  
  }    
  
  
  }

此类用于将ValueBean和DatabaseEntry进行转换，两个方法中的属性读写顺序要统一。

3.SecondaryKeyCreator，第二主键生成器

 
 
 
  
  
  public class SecondKeyCreator implements SecondaryKeyCreator{    
  
  
  private TupleBinding theBinding;    
  
  
  SecondKeyCreator(TupleBinding theBinding) {    
  
  
  this.theBinding = theBinding;    
  
  
  }    
  
  
  @Override    
  
  
  public boolean createSecondaryKey(SecondaryDatabase secondary,    
  
  
  DatabaseEntry key, DatabaseEntry data, DatabaseEntry result) {    
  
  
  ValueBean v =    
  
  
  (ValueBean) theBinding.entryToObject(data);    
  
  
  String time=v.getInsertTime();    
  
  
  result.setData(time.getBytes());    
  
  
  return true;    
  
  
  }    
  
  
  }

指定insertTime属性作为第二主键。

在插入一个新数据时生成insertTime十分关键，尤其在高并发和互为主从同步时极易出现“第二主键重复”的错误，造成数据无法插入，我了使用当前时间毫秒数+AtomicInteger自增+hostName的asc码之和，保证insertTime的前后大小顺序。

System.currentTimeMillis()*1000000+(add_num.getAndIncrement()%1000)*1000 + host_key

4.创建第二数据库，用于存储secondkey

 
 
 
  
  
  SecondaryConfig mySecConfig = new SecondaryConfig();    
  
  
  mySecConfig.setAllowCreate(true);    
  
  
  mySecConfig.setSortedDuplicates(false);    
  
  
  TupleBinding tb =new ValueBeanBinding();    
  
  
  SecondKeyCreator  keyCreator = new  SecondKeyCreator(tb);    
  
  
  mySecConfig.setKeyCreator(keyCreator);    
  
  
  mySecConfig.setTransactional(envConfig.getTransactional());    
  
  
  String secDbName = "mySecondaryDatabase";    
  
  
  mySecDb = myEnv.openSecondaryDatabase(null, secDbName,  storeDb, mySecConfig);

到此，便可以使用SecondaryCursor的getNext()和getPrev()前后遍历了，getSearchKey()可以找到你想要的位置。

关于Berkeley DB使用SecondKey给数据排序的实现方法的相关知识就介绍到这里了，希望本次的介绍能够对您有所收获！

分享文章：BerkeleyDB使用SecondKey给数据排序的实现方法
分享链接：http://www.csdahua.cn/qtweb/news19/369819.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：快上网

成都快上网为您推荐相关内容