python写couchbase增删改查

#coding=utf-8 from couchbase.bucket import Bucket from couchbase.n1ql import N1QLQuery from flask import jsonify from ..common.gisquery import getuuid import sys,os class CouchData(): def connect_db(self,bucket_name): try: self.bucket=Bucket('couchbase://localhost/%s'%bucket_name) return self.bucket except Exception,ex: return ex #insert+update def upsert_data(self,key,value): # try: self.bucket.upsert(key,value) return "insert success" # except Exception,ex: # return ex #导入一个路径下的所有json文件 def upsert_multi_data(self,path): # path = r"C:\Program Files\Couchbase\Server\samples\travel-sample\docs\\" import os files = os.listdir(path) for file in files: ff = open(path + file) content = ff.read() ff.close() self.upsert_data(file.strip(".json"), content) return "mulinsert success" def remove_data(self,key): try: self.bucket.remove(key) except Exception,ex: return ex def query_data(self,key): query=N1QLQuery("select * from %s"%self.bucket) datalist=[i for i in self.bucket.n1ql_query(query)] return jsonify(datalist)