java中利用mongodb存储protobuf
最近由于项目需要，大致研究了一下protobuf的java使用。说实话，习惯了C++的protobuf，java用起来真别扭。java在mongodb中的存储其实非常方便，假设有定义一个proto，如下所示：
message User
{
required int64 id = 1;
required string name = 2;
}
那么可以利用一下代码，对protobuf进行存储
// 设置user
User.Builder builder = User.newBuilder();
builder.setId(123);
builder.setName("abc");
// 实例化user
User user = builder.build();
// 序列化成byte数组
byte[] ub = user.toByteArray();
// 与mongodb建立连接
MongoClient cli = new MongoClient("localhost", 2000);
// 切换至user_info数据库
DB db = cli.getDB("user_info");
// 选择集合user
DBCollection coll = db.getCollection("user");
// 插入更新数据
DBObject condition = new BasicDBObject();
condition.put("user_id", user.getId());
DBObject data = new BasicDBObject();
data.put("user_id", user.getId());
data.put("model", ub);
// 第三个参数设置为true，表示upsert
coll.update(condition, data, true, false);
如果需要获得存储的数据，可利用一下代码：
DBCursor cur = coll.find(condition);
while(cur.hasNext())
{
DBObject obj = cur.next();
Binary m = (Binary)result.get("model");
byte[] xx = m.getData();
break;
}
如果需要跨语言平台获取数据，这里以C++为例：
std::string content;
std::auto_ptr cursor =
conn->query("user_info.user", query.obj());
while (cursor->more())
{
mongo::BSONObj obj = cursor->next();
if (!obj.isEmpty() && obj.isValid())
{
mongo::BSONElement elm = obj.getField("model");
int len = 0;
const char *b = elm.binData(len);
content.assign(b, len);
ret = true;
}
break;
}
页:
[1]