日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
BerkeleyDB使用SecondKey給數(shù)據(jù)排序的實(shí)現(xiàn)方法

Berkeley DB使用SecondKey數(shù)據(jù)排序的實(shí)現(xiàn)方法是本文我們主要要介紹的內(nèi)容,在做項(xiàng)目的時(shí)候用到了nosql數(shù)據(jù)庫BDB,借此機(jī)會研究了一下它的用法。它的官方示例和文檔比較豐富,感覺比較容易學(xué)習(xí)。在開發(fā)過程中出現(xiàn)了一個(gè)需求,要把數(shù)據(jù)根據(jù)插入時(shí)間遍歷,個(gè)人認(rèn)為通過第二主鍵(SecondKey)比較容易實(shí)現(xiàn)。

以下是我的基本實(shí)現(xiàn)過程:

1.在ValueBean中加入insertTime屬性

 
 
 
  1. public class ValueBean{    
  2. private String insertTime;    
  3. private String hostName;    
  4. private byte[] value;    
  5. public String getHostName() {    
  6. return hostName;    
  7. }    
  8. public void setHostName(String hostName) {    
  9. this.hostName = hostName;    
  10. }    
  11. public String getInsertTime() {    
  12. return insertTime;    
  13. }    
  14. public void setInsertTime(String insertTime) {    
  15. this.insertTime = insertTime;    
  16. }    
  17. public byte[] getValue() {    
  18. return value;    
  19. }    
  20. public void setValue(byte[] value) {    
  21. this.value = value;    
  22. }    
  23. }   

 

其中的hostName屬性在主從同步和生成插入時(shí)間時(shí)用到,value屬性就是key-value中的值

2.TupleBinding類

 
 
 
  1. public class ValueBeanBinding extends TupleBinding {    
  2. @Override    
  3. public ValueBean entryToObject(TupleInput input) {    
  4. String time = input.readString();    
  5. String name = input.readString();    
  6. byte[] value = new byte[input.getBufferLength()-input.getBufferOffset()];//獲得value長度     
  7. input.read(value);    
  8. ValueBean data = new ValueBean();    
  9. data.setInsertTime(time);    
  10. data.setHostName(name);    
  11. data.setValue(value);    
  12. return data;    
  13. }    
  14. @Override    
  15. public void objectToEntry(ValueBean object, TupleOutput output) {    
  16. ValueBean value = object;    
  17. output.writeString(value.getInsertTime());    
  18. output.writeString(value.getHostName());    
  19. output.write(value.getValue());    
  20. }    
  21. }   

 

此類用于將ValueBean和DatabaseEntry進(jìn)行轉(zhuǎn)換,兩個(gè)方法中的屬性讀寫順序要統(tǒng)一。

3.SecondaryKeyCreator,第二主鍵生成器

 
 
 
  1. public class SecondKeyCreator implements SecondaryKeyCreator{    
  2. private TupleBinding theBinding;    
  3. SecondKeyCreator(TupleBinding theBinding) {    
  4. this.theBinding = theBinding;    
  5. }    
  6. @Override    
  7. public boolean createSecondaryKey(SecondaryDatabase secondary,    
  8. DatabaseEntry key, DatabaseEntry data, DatabaseEntry result) {    
  9. ValueBean v =    
  10. (ValueBean) theBinding.entryToObject(data);    
  11. String time=v.getInsertTime();    
  12. result.setData(time.getBytes());    
  13. return true;    
  14. }    
  15. }   

 

指定insertTime屬性作為第二主鍵。

在插入一個(gè)新數(shù)據(jù)時(shí)生成insertTime十分關(guān)鍵,尤其在高并發(fā)和互為主從同步時(shí)極易出現(xiàn)“第二主鍵重復(fù)”的錯(cuò)誤,造成數(shù)據(jù)無法插入,我了使用當(dāng)前時(shí)間毫秒數(shù)+AtomicInteger自增+hostName的asc碼之和,保證insertTime的前后大小順序。

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

4.創(chuàng)建第二數(shù)據(jù)庫,用于存儲secondkey

 
 
 
  1. SecondaryConfig mySecConfig = new SecondaryConfig();    
  2. mySecConfig.setAllowCreate(true);    
  3. mySecConfig.setSortedDuplicates(false);    
  4. TupleBinding tb =new ValueBeanBinding();    
  5. SecondKeyCreator  keyCreator = new  SecondKeyCreator(tb);    
  6. mySecConfig.setKeyCreator(keyCreator);    
  7. mySecConfig.setTransactional(envConfig.getTransactional());    
  8. String secDbName = "mySecondaryDatabase";    
  9. mySecDb = myEnv.openSecondaryDatabase(null, secDbName,  storeDb, mySecConfig);   

 

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

關(guān)于Berkeley DB使用SecondKey給數(shù)據(jù)排序的實(shí)現(xiàn)方法的相關(guān)知識就介紹到這里了,希望本次的介紹能夠?qū)δ兴斋@!


新聞名稱:BerkeleyDB使用SecondKey給數(shù)據(jù)排序的實(shí)現(xiàn)方法
URL分享:http://www.dlmjj.cn/article/dhojoij.html