Lines Matching full:commit
194 """Private method for function commit to call for retry.
196 return self.con.commit()
199 def commit(self):
200 """Commit the sql transaction."""
334 def _exec_sql_with_commit(self, sql, values, commit):
339 self.con.commit()
344 if commit:
345 self.con.commit()
348 def insert(self, table, data, commit=None):
357 @param commit: If commit the transaction .
367 self._exec_sql_with_commit(cmd, values, commit)
370 def delete(self, table, where, commit = None):
375 @param commit: If commit the transaction .
378 if commit is None:
379 commit = self.autocommit
385 self._exec_sql_with_commit(sql, values, commit)
388 def update(self, table, data, where, commit = None):
398 @param commit: If commit the transaction .
400 if commit is None:
401 commit = self.autocommit
414 self._exec_sql_with_commit(cmd, values, commit)
417 def delete_job(self, tag, commit = None):
421 @param commit: If commit the transaction .
436 def insert_job(self, tag, job, parent_job_id=None, commit=None):
442 @param commit: If commit the transaction .
448 job.machine_idx = self.insert_machine(job, commit=commit)
452 self.update_machine_information(job, commit=commit)
476 self.update('tko_jobs', data, {'job_idx': job.index}, commit=commit)
478 self.insert('tko_jobs', data, commit=commit)
480 self.update_job_keyvals(job, commit=commit)
482 self.insert_test(job, test, commit=commit)
488 def update_job_keyvals(self, job, commit=None):
492 @param commit: If commit the transaction .
500 self.update('tko_job_keyvals', data, where=where, commit=commit)
502 self.insert('tko_job_keyvals', data, commit=commit)
505 def insert_test(self, job, test, commit = None):
510 @param commit: If commit the transaction .
512 kver = self.insert_kernel(test.kernel, commit=commit)
523 {'test_idx': test_idx}, commit=commit)
531 self.insert('tko_tests', data, commit=commit)
541 commit=commit)
549 commit=commit)
556 self.insert('tko_test_attributes', data, commit=commit)
561 self.insert('tko_test_labels_tests', data, commit=commit)
593 def insert_machine(self, job, commit = None):
597 @param commit: If commit the transaction .
600 self.insert('tko_machines', machine_info, commit=commit)
604 def update_machine_information(self, job, commit = None):
608 @param commit: If commit the transaction .
613 commit=commit)
642 def insert_kernel(self, kernel, commit = None):
646 @param commit: If commit the transaction .
666 commit=commit)
676 self.insert_patch(kver, patch, commit=commit)
680 def insert_patch(self, kver, patch, commit = None):
685 @param commit: If commit the transaction .
694 commit=commit)
