做网站的成功案例/厦门网站的关键词自动排名

# encoding: utf-8
__author__ = 'yeayee'  2015-07from pymongo import MongoClient
from pymongo import errors
import json
from datetime import date, datetime# 数据库日志配置
from log import Logger
my_logger = Logger('mongodb', 'mongodb.log', 'DEBUG')
my_logger.set_file_level('DEBUG')
my_logger.set_stream_level('WARNING')  # WARNING DEBUG
my_logger.set_stream_handler_fmt('%(message)s')
my_logger.load()
logger = my_logger.logger
# my_logger.get_memory_usage()class Mongodb():"""自定义mongodb工具"""def __init__(self, db_config, db_name=None):self.db_config = db_configif db_name is not None:self.db_config['database'] = db_nametry:# 实例化mongodbself.conn = MongoClient(self.db_config['host'], self.db_config['port'])# 获取数据库对象(选择/切换)self.db = self.conn.get_database(self.db_config['database'])except errors.ServerSelectionTimeoutError, e:logger.error('连接超时：%s' % e)except Exception as e:logger.error(e)@staticmethoddef __default(obj):"""支持datetime的json encodeTypeError: datetime.datetime(2015, 10, 21, 8, 42, 54) is not JSON serializable:param obj::return:"""if isinstance(obj, datetime):return obj.strftime('%Y-%m-%d %H:%M:%S')elif isinstance(obj, date):return obj.strftime('%Y-%m-%d')else:raise TypeError('%r is not JSON serializable' % obj)def close_conn(self):"""关闭连接关闭所有套接字的连接池和停止监控线程。如果这个实例再次使用它将自动重启和重新启动线程"""self.conn.close()def find_one(self, table_name, condition=None):"""查询单条记录:param table_name::param condition::return:"""return self.db.get_collection(table_name).find_one(condition)def find_all(self, table_name, condition=None):"""查询多条记录:param table_name::param condition::return:"""return self.db.get_collection(table_name).find(condition)def count(self, table_name, condition=None):"""查询记录总数:param table_name::param condition::return:"""return self.db.get_collection(table_name).count(condition)def distinct(self, table_name, field_name):"""查询某字段去重后值的范围:param table_name::param field_name::return:"""return self.db.get_collection(table_name).distinct(field_name)def insert(self, table_name, data):"""插入数据:param table_name::param data::return:"""try:ids = self.db.get_collection(table_name).insert(data)return idsexcept Exception, e:logger.error('插入失败：%s' % e)return Nonedef update(self, table_name, condition, update_data, update_type='set'):"""批量更新数据upsert : 如果不存在update的记录，是否插入；true为插入，默认是false，不插入。:param table_name::param condition::param update_data::param update_type: 范围：['inc', 'set', 'unset', 'push', 'pushAll', 'addToSet', 'pop', 'pull', 'pullAll', 'rename']:return:"""if update_type not in ['inc', 'set', 'unset', 'push', 'pushAll', 'addToSet', 'pop', 'pull', 'pullAll', 'rename']:logger.error('更新失败，类型错误：%s' % update_type)return Nonetry:result = self.db.get_collection(table_name).update_many(condition, {'$%s' % update_type: update_data})logger.info('更新成功，匹配数量：%s；更新数量：%s' % (result.matched_count, result.modified_count))return result.modified_count  # 返回更新数量，仅支持MongoDB 2.6及以上版本except Exception, e:logger.error('更新失败：%s' % e)return Nonedef remove(self, table_name, condition=None):"""删除文档记录:param table_name::param condition::return:"""result = self.db.get_collection(table_name).remove(condition)if result.get('err') is None:logger.info('删除成功，删除行数%s' % result.get('n', 0))return result.get('n', 0)else:logger.error('删除失败：%s' % result.get('err'))return Nonedef output_row(self, table_name, condition=None, style=0):"""格式化输出单个记录style=0 键值对齐风格style=1 JSON缩进风格:param table_name::param condition::param style::return:"""row = self.find_one(table_name, condition)if style == 0:# 获取KEY最大的长度作为缩进依据max_len_key = max([len(each_key) for each_key in row.keys()])str_format = '{0: >%s}' % max_len_keykeys = [str_format.format(each_key) for each_key in row.keys()]result = dict(zip(keys, row.values()))print ('**********  表名[%s]  **********' % table_name)for key, item in result.items():print key, ':', itemelse:print (json.dumps(row, indent=4, ensure_ascii=False, default=self.__default))def output_rows(self, table_name, condition=None, style=0):"""格式化输出批量记录style=0 键值对齐风格style=1 JSON缩进风格:param table_name::param condition::param style::return:"""rows = self.find_all(table_name, condition)total = self.count(table_name, condition)if style == 0:count = 0for row in rows:# 获取KEY最大的长度作为缩进依据max_len_key = max([len(each_key) for each_key in row.keys()])str_format = '{0: >%s}' % max_len_keykeys = [str_format.format(each_key) for each_key in row.keys()]result = dict(zip(keys, row.values()))count += 1print ('**********  表名[%s]  [%d/%d]  **********' % (table_name, count, total))for key, item in result.items():print key, ':', itemelse:for row in rows:print (json.dumps(row, indent=4, ensure_ascii=False, default=self.__default))

# encoding: utf-8
__author__ = 'yeayee'  2015-08
from pymongo import MongoClient
client = MongoClient(host='localhost', port=27017)
db = client.test # 直接建立一个测试数据库
collection = db.students # 在上数据库建立一个集合
student = {'id': '20170101','name': 'Jordan','age': 20,'gender': 'male'
}  # 声明一条数据# 增
collection.insert(student)  # 插入数据
# 改，发现年龄错了，加1岁
collection.update_one({'name': 'Jordan'}, {'$inc': {'age': 1}})
# 查
result = collection.find_one({'name': 'Jordan'})  # 查询数据，返回的是一个游标
print(result)
# <pymongo.results.UpdateResult object at 0x10c6384c8>
# 删
result = collection.remove({'name': 'Jordan'})  # 返回删除状态
print(result)
# {'ok': 1, 'n': 1}