提交 c40c2172 编写于 作者: J jinhai

Update for group handle


Former-commit-id: e5f782eda6b90b4c4da4a87003df54ec168f38a4
上级 62760066
from engine.model.group_table import GroupTable from engine.model.group_table import GroupTable
from engine.model.file_table import FileTable from engine.model.file_table import FileTable
from engine.controller.error_code import ErrorCode from engine.controller.error_code import ErrorCode
from engine import db
class MetaManager(object): class MetaManager(object):
def Sync(self): @staticmethod
def Sync():
db.session.commit() db.session.commit()
def AddGroup(self, group_name, dimension): @staticmethod
group = GroupTable.query.filter(GroupTable.group_name==group_id).first() def AddGroup(group_name, dimension):
if group: new_group = GroupTable(group_name, dimension)
return ErrorCode.ALREADY_EXIST, group_name
else: # add into database
new_group = GroupTable(group_name, dimension) db.session.add(new_group)
GroupHandler.CreateGroupDirectory(group_id) db.session.commit()
# add into database return ErrorCode.SUCCESS_CODE, group_name
db.session.add(new_group)
self.Sync()
return ErrorCode.SUCCESS_CODE, group_name
@staticmethod @staticmethod
def GetGroup(group_name): def GetGroup(group_name):
......
...@@ -3,7 +3,7 @@ from engine.settings import DATABASE_DIRECTORY ...@@ -3,7 +3,7 @@ from engine.settings import DATABASE_DIRECTORY
class StorageManager(object): class StorageManager(object):
@staticmethod @staticmethod
def CreateGroup(group_name): def AddGroup(group_name):
path = StorageManager.GetGroupDirectory(group_name) path = StorageManager.GetGroupDirectory(group_name)
path = path.strip() path = path.strip()
path=path.rstrip("\\") path=path.rstrip("\\")
......
...@@ -27,12 +27,8 @@ class VectorEngine(object): ...@@ -27,12 +27,8 @@ class VectorEngine(object):
if(error == ErrorCode.SUCCESS_CODE): if(error == ErrorCode.SUCCESS_CODE):
return ErrorCode.FAULT_CODE, group_name return ErrorCode.FAULT_CODE, group_name
else: else:
StorageManager.CreateGroup(group_name) StorageManager.AddGroup(group_name)
new_group = GroupTable(group_name, dimension) MetaManager.AddGroup(group_name, dimension)
# add into database
db.session.add(new_group)
db.session.commit()
return VectorEngine.SUCCESS_CODE, group_name return VectorEngine.SUCCESS_CODE, group_name
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册