如何在Go语言中通过Key后缀从LevelDb获取对应值？

LevelDB本身不直接支持按Key后缀查询——它的底层存储是按Key的字典序排序的，前缀查询能借助这个特性快速定位范围，但后缀匹配没法直接用内置的范围迭代器实现。不过我们可以通过两种方式来实现需求：

1. 预存反转Key（推荐大数据量场景） #

核心思路是把原Key反转后存入LevelDB，这样后缀查询就转化为反转Key的前缀查询，能复用LevelDB高效的前缀迭代能力。

实现步骤： #

• 写入数据时：同时存入原Key-Value和反转Key-原Key（或反转Key-Value，根据业务需求选择）
• 查询后缀时：把目标后缀反转，用反转后的字符串作为前缀去迭代LevelDB，拿到匹配的反转Key后再反转回原Key，最终获取对应的值

代码示例： #

首先实现一个字节反转工具函数：

import "bytes"

func reverseBytes(b []byte) []byte {
    reversed := make([]byte, len(b))
    for i := range b {
        reversed[i] = b[len(b)-1-i]
    }
    return reversed
}

写入数据：

// 假设db是已打开的LevelDB实例
originalKey := []byte("order_20240520")
value := []byte("paid")

// 写入原Key
if err := db.Put(originalKey, value, nil); err != nil {
    // 处理写入错误
}

// 写入反转Key，这里存原Key以便后续还原
reversedKey := reverseBytes(originalKey)
if err := db.Put(reversedKey, originalKey, nil); err != nil {
    // 处理写入错误
}

按后缀查询：

// 要查询所有后缀为"20240520"的Key
targetSuffix := []byte("20240520")
reversedPrefix := reverseBytes(targetSuffix)

iter := db.NewIterator(&leveldb.ReadOptions{})
defer iter.Release()

// 定位到反转前缀的起始位置，开始迭代
for iter.Seek(reversedPrefix); iter.Valid(); iter.Next() {
    currentReversedKey := iter.Key()
    // 确保当前Key确实以反转前缀开头，避免边界匹配问题
    if !bytes.HasPrefix(currentReversedKey, reversedPrefix) {
        break
    }
    // 还原原Key
    originalKey := reverseBytes(currentReversedKey)
    // 获取对应的值
    value, err := db.Get(originalKey, nil)
    if err != nil {
        // 处理查询错误，继续下一个
        continue
    }
    // 输出结果
    println("匹配的Key:", string(originalKey), "Value:", string(value))
}

// 检查迭代过程中的错误
if err := iter.Error(); err != nil {
    // 处理迭代错误
}

2. 全量迭代过滤（适合小数据量场景） #

如果你的数据量不大，可以直接遍历LevelDB中所有Key，逐个检查是否以目标后缀结尾。这种方法实现简单，但效率较低，数据量大时不推荐。

代码示例： #

targetSuffix := []byte("_log")
iter := db.NewIterator(&leveldb.ReadOptions{})
defer iter.Release()

// 遍历所有Key
for iter.First(); iter.Valid(); iter.Next() {
    key := iter.Key()
    if bytes.HasSuffix(key, targetSuffix) {
        value := iter.Value()
        println("匹配的Key:", string(key), "Value:", string(value))
    }
}

// 检查迭代错误
if err := iter.Error(); err != nil {
    // 处理错误
}

内容的提问来源于stack exchange，提问作者Nazarevsky