mongo.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
' 操作mongo '
__author__ = 'zzyfisher'
import json
from pymongo import MongoClient
import time

from xitekInfo import ThreadInfo,PostInfo,PageInfo,ForumInfo
	
class MongoStore:
	#构造
	def __init__(self):		
		self.conn=b""
		self.db=b""
		
	#打开db
	def open(self):
		self.conn = MongoClient("127.0.0.1",27017)
		self.db = self.conn.xitek
		
	#保存到db-thread（主题）
	def saveThread(self,thread):
		j= json.dumps(thread, default=lambda thread: thread.__dict__)
		self.db.threads.insert(json.loads(j))
	def saveForum(self,forum):
		j= json.dumps(forum, default=lambda forum: forum.__dict__)
		print(j)
		self.db.forums.insert(json.loads(j))
	def savePost(self,post):
		j= json.dumps(post, default=lambda post: post.__dict__)
		self.db.posts.insert(json.loads(j))
		
		
if __name__=='__main__':	
	ms = MongoStore()
	ms.open()
	forum = ForumInfo()
	forum.forumId=100
	forum.forumName="测试论坛"
	ms.saveForum(forum)
	post = PostInfo()
	post.threadId=1
	post.content="hello"
	post.postId="2"
	ms.savePost(post)