Django操作mongodb

我的项目中已经使用了mysql，现在设计了两个表想要采用mongodb数据库进行存储。

步骤如下（mongodb安装启动在https://www.cnblogs.com/huanhuaqingfeng/p/11188024.html中查看）

1，安装mongoengine

     pip  install mongoengine

     在django中，mongoengine是django与mongodb数据库的连接器

2， 修改settings.py

      

DATABASES = {

    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'builddatabase',
        'USER': 'root',
        'PASSWORD': 'likeshe',
        'HOST': '127.0.0.1',
        'PORT': '3306',
    },
    'db1': {
        'ENGINE':None,
    }
}

import mongoengine     #导入mongoengine

conn = mongoengine.connect("Print_Analysis")  ##Print_Analysis ，我的mongodb数据库的名字

3，在我的应用Print_Analysis的models.py 中添加表类

import mongoengine

class log_info(mongoengine.Document):
    fun_name=mongoengine.StringField(max_length=100)
    dir_name = mongoengine.StringField(max_length=100)
    log_name = mongoengine.StringField(max_length=100)
    path = mongoengine.StringField(max_length=255)
    status = mongoengine.StringField(max_length=16)
    case_num=mongoengine.IntField()
    half_case_num = mongoengine.IntField()
    fail_case_num = mongoengine.IntField()
    line_num = mongoengine.IntField()

class case_info(mongoengine.Document):
    log=mongoengine.ReferenceField(log_info)
    funtion = mongoengine.StringField(max_length=255)
    exe_status = mongoengine.StringField(max_length=16)
    line_start = mongoengine.IntField()
    line_end = mongoengine.IntField()
    error_count = mongoengine.IntField()
    level = mongoengine.IntField()
    sucess_num = mongoengine.IntField()
    fail_num = mongoengine.IntField()
    status_info = mongoengine.ListField()

4，在Print_Analysis的view.py 中添加测试代码

def anlaysis_result_test():

     var = log_info.objects.create(fun_name="123", dir_name="456", log_name="11.log", path="/mnt/disk2/timetask/Star_HD_Trunk_Iteration_Time/02.01.01.01-3-190608183846/02.01.01.01-3-190608183846-732242087-20190608184531.log",
                       status="sucess",                       case_num=0, half_case_num=0, fail_case_num=0, line_num=0)

     print(var)

     log_info_obj = log_info.objects.get(log_name="11.log")
     print(log_info_obj)

     case_info.objects.create(log=log_info_obj,funtion="S123",exe_status="SUCESS",line_start=0,line_end=0,error_count=0,level=0,sucess_num=0,fail_num=0,status_info=None)
     case_info.objects.create(log=log_info_obj, funtion="S124", exe_status="SUCESS", line_start=0, line_end=0,
                   error_count=0, level=0, sucess_num=0, fail_num=0, status_info=None)
     case_info.objects.create(log=log_info_obj, funtion="S125", exe_status="SUCESS", line_start=0, line_end=0,
                   error_count=0, level=0, sucess_num=0, fail_num=0, status_info=None)

     return {'status': 'already'}

def index(request):    
      logger.info("request.method=%s" ,request.method)
      #logger.info("request.body=%s" ,request.body)
      logger.info("content_type=%s",request.content_type)
      logger.info(   "user=%s",request.user.username)
      logger.info( "is_authenticated=%d",request.user.is_authenticated())
      logger.info( "request.path=%s",request.path)
      if not request.user.is_authenticated():
         return HttpResponseForbidden()

      if request.method=='POST':
         body = eval(request.body)
         op_type = str(body['op_type'])
         if op_type == 'anlaysis_result_test':
            result=anlaysis_result_test()
            return JsonResponse(result)

5，url路由，Print_Analysis添加在urls.py和settings.py中搞定，这里不说了。（可以查看https://www.cnblogs.com/huanhuaqingfeng/p/11101751.html）

6，python测试代码

def anlaysis_test():    
    data = {}
    data['op_type'] = "anlaysis_result_test"
    response = httprequest.post(url_path + "print_analysis/", json=data)
    print response.text

if __name__ == '__main__':          

anlaysis_test(）

7，查看数据库

   执行完测试后，查看数据库
   ./mongo进入shell

  show dbs 显示所有存在的mongodb数据库

   use Print_Analysis 切换到我的Print_Analysis 数据库

  show tables 显示Print_Analysis中的表（又叫集合）

  db.log_info.find() 查看集合log_info中的数据