本文共 1062 字,大约阅读时间需要 3 分钟。
基本操作
import lmdbimport os, sysdef initialize(): env = lmdb.open("lmdb_dir") #如果没有就创建lmdb_dir目录 return envdef insert(env, sid, name): txn = env.begin(write=True) txn.put(str(sid).encode(), name.encode()) txn.commit()def delete(env, sid): txn = env.begin(write=True) txn.delete(str(sid).encode()) txn.commit()def update(env, sid, name): txn = env.begin(write=True) txn.put(str(sid).encode(), name.encode()) txn.commit()def search(env, sid): txn = env.begin() name = txn.get(str(sid).encode()) return namedef display(env): txn = env.begin() cur = txn.cursor() for key, value in cur: print(key, value)env = initialize()print("Insert 3 records.")insert(env, 1, "Alice")insert(env, 2, "Bob")insert(env, 3, "Peter")display(env)print("Delete the record where sid = 1.")delete(env, 1)display(env)print("Update the record where sid = 3.")update(env, 3, "Mark")display(env)print("Get the name of student whose sid = 3.")name = search(env, 3)print(name)# 最后需要关闭lmdb数据库env.close()# 执行系统命令# os.system("rm -r lmdb_dir")
转载地址:http://pgygf.baihongyu.com/