31 def updateResourcesData(self, updated_resources):
33 input_back_log_one_task = dbResources(updated_resources)
34 self.dbi.insert(input_back_log_one_task)
35 if self.dbi.getError() != CONSTANTS.DBI_SUCCESS_CODE:
37 print "One insert error!" 45 fetch_back_log_tasks = dbResources(updated_resources)
46 fetched_back_log_tasks = self.dbi.fetch(fetch_back_log_tasks,
"nodeId=%s"%fetch_back_log_tasks.nodeId)
47 if self.dbi.getError() != CONSTANTS.DBI_SUCCESS_CODE:
49 print "One fetch error!" 54 print fetched_back_log_tasks
59 fetch_back_log_tasks = dbResources(updated_resources)
60 fetched_back_log_tasks = self.dbi.fetchAll(fetch_back_log_tasks)
61 if self.dbi.getError() != CONSTANTS.DBI_SUCCESS_CODE:
63 print "fetch all for one object error!" 68 for task
in fetched_back_log_tasks:
75 update_back_log_tasks = dbResources(updated_resources)
76 updated_back_log_tasks = self.dbi.update(update_back_log_tasks,
"nodeId=%s"%update_back_log_tasks.nodeId)
77 if self.dbi.getError() != CONSTANTS.DBI_SUCCESS_CODE:
79 print "update one object error!" 84 for task
in updated_back_log_tasks:
91 delete_back_log_tasks = dbResources(updated_resources)
92 deleted_back_log_tasks = self.dbi.delete(delete_back_log_tasks,
"nodeId=%s"%delete_back_log_tasks.nodeId)
93 if self.dbi.getError() != CONSTANTS.DBI_SUCCESS_CODE:
95 print "delete one object error!" 100 for task
in deleted_back_log_tasks:
106 delete_back_log_tasks = dbResources(updated_resources)
107 deleted_back_log_tasks = self.dbi.deleteAll(delete_back_log_tasks)
108 if self.dbi.getError() != CONSTANTS.DBI_SUCCESS_CODE:
110 print "delete all for one object error!" 115 for task
in deleted_back_log_tasks: