|
|
马上注册,结交更多好友,享用更多功能^_^
您需要 登录 才可以下载或查看,没有账号?立即注册
x
本帖最后由 康小泡 于 2017-11-9 11:24 编辑
- #-*- encoding:utf-8 -*-
- import pymongo
- import datetime
- import time
- import json
- from pymongo import MongoClient
- def GetDB():
- with open('workspace/confs/demo.conf' , 'r') as f:
- json_obj = json.load(f)
- mongoStr = json_obj['dbmanager0']['mongo']
- # print mongoStr
- DBname = str(mongoStr['db'])
- DBuser = str(mongoStr['user'])
- DBpass = str(mongoStr['pwd'])
- DBip = str(mongoStr['ip']) + ":" + str(mongoStr['port'])
- return DBname,DBuser,DBpass,DBip
- def CreateConnection(DBname , DBuser , DBpass , DBip):
- Mongo = 'mongodb://'+DBip+'/'
- client = MongoClient(Mongo)#创建数据库连接
- db = client[DBname] #创建DBname数据库的连接
- db.authenticate(DBuser,DBpass) #连接数据库使用的账户和密码
- # print db.collection_names()
- tableName = db.collection_names()
- return db,client,tableName
- def DeleteTable(a,b):
- db = a
- array1 = b
- # print array1
- for i in array1:
- if i != 'system.indexes':
- # print i
- db[i].remove()
- if __name__ == '__main__':
- DBname , DBuser , DBpass , DBip = GetDB()
- db , client ,tableName = CreateConnection(DBname , DBuser , DBpass , DBip)
- DeleteTable(db,tableName)
- print 'Success'
复制代码 |
|