Lines Matching full:commit
239 """Private method for function commit to call for retry.
241 return self.con.commit()
244 def commit(self): member in db_sql
245 """Commit the sql transaction."""
379 def _exec_sql_with_commit(self, sql, values, commit): argument
384 self.con.commit()
389 if commit:
390 self.con.commit()
393 def insert(self, table, data, commit=None): argument
402 @param commit: If commit the transaction .
412 self._exec_sql_with_commit(cmd, values, commit)
415 def delete(self, table, where, commit = None): argument
420 @param commit: If commit the transaction .
423 if commit is None:
424 commit = self.autocommit
430 self._exec_sql_with_commit(sql, values, commit)
433 def update(self, table, data, where, commit = None): argument
443 @param commit: If commit the transaction .
445 if commit is None:
446 commit = self.autocommit
459 self._exec_sql_with_commit(cmd, values, commit)
462 def delete_job(self, tag, commit = None): argument
466 @param commit: If commit the transaction .
481 def insert_job(self, tag, job, commit=None): argument
486 @param commit: If commit the transaction .
495 'tko_jobs', data, {'job_idx': job.job_idx}, commit=commit)
497 self.insert('tko_jobs', data, commit=commit)
518 def insert_or_update_task_reference(self, job, reference_type, commit=None): argument
525 @param commit: Whether to commit this transaction.
546 commit=commit)
549 self.insert('tko_task_references', data, commit=commit)
553 def update_job_keyvals(self, job, commit=None): argument
557 @param commit: If commit the transaction .
565 self.update('tko_job_keyvals', data, where=where, commit=commit)
567 self.insert('tko_job_keyvals', data, commit=commit)
570 def insert_test(self, job, test, commit = None): argument
575 @param commit: If commit the transaction .
577 kver = self.insert_kernel(test.kernel, commit=commit)
588 {'test_idx': test_idx}, commit=commit)
596 self.insert('tko_tests', data, commit=commit)
606 commit=commit)
614 commit=commit)
622 self.insert('tko_test_attributes', data, commit=commit)
630 self.insert('tko_test_labels_tests', data, commit=commit)
662 def insert_or_update_machine(self, job, commit=None): argument
668 @param commit: Whether to commit the database transaction.
672 job.machine_idx = self._insert_machine(job, commit=commit)
676 self._update_machine_information(job, commit=commit)
696 def _insert_machine(self, job, commit = None): argument
700 @param commit: If commit the transaction .
703 self.insert('tko_machines', machine_info, commit=commit)
707 def _update_machine_information(self, job, commit = None): argument
711 @param commit: If commit the transaction .
716 commit=commit)
745 def insert_kernel(self, kernel, commit = None): argument
749 @param commit: If commit the transaction .
769 commit=commit)
779 self.insert_patch(kver, patch, commit=commit)
783 def insert_patch(self, kver, patch, commit = None): argument
788 @param commit: If commit the transaction .
797 commit=commit)