diff --git versioncontrol_git.log.inc versioncontrol_git.log.inc
index 00aaeaf..fa449e1 100644
--- versioncontrol_git.log.inc
+++ versioncontrol_git.log.inc
@@ -56,6 +56,7 @@ $autoinc_step = variable_get('versioncontrol_git_autoincrement_step', 1);
     }
     $numlines = _versioncontrol_git_log_process_numstat($file_names[0]);
 
+    db_query("BEGIN");
     $values = array();
     $start = db_result(db_query('SELECT MAX(vc_op_id) FROM {versioncontrol_operations}'));
     $query = db_insert('versioncontrol_operations')->fields(array('type', 'repo_id', 'date', 'author', 'author_uid', 'committer', 'committer_uid', 'revision', 'message'));
@@ -82,6 +83,7 @@ $autoinc_step = variable_get('versioncontrol_git_autoincrement_step', 1);
       $query->execute();
     }
     $end = db_result(db_query('SELECT MAX(vc_op_id) FROM {versioncontrol_operations} WHERE repo_id = '. $repo_id));
+    db_query("COMMIT");
     if ($start != $end) {
       watchdog('vc_git', "Concurrency problem during inital import of {versioncontrol_operations} for repo id #$repo_id. Expected $start, got $end. Recovering.");
       $result = db_query("SELECT vc_op_id, revision FROM {versioncontrol_operations} WHERE repo_id = $repo_id ORDER BY vc_op_id ASC");
@@ -96,6 +98,7 @@ $autoinc_step = variable_get('versioncontrol_git_autoincrement_step', 1);
       }
     }
 
+    db_query("BEGIN");
     $values = array();
     $start = db_result(db_query('SELECT MAX(item_revision_id) FROM {versioncontrol_item_revisions}')); //Make this happen in the same transaction.
     if (!is_numeric($start) || $start == 0) {
@@ -137,6 +140,7 @@ $autoinc_step = variable_get('versioncontrol_git_autoincrement_step', 1);
       $query->execute();
     }
     $end = db_result(db_query('SELECT MAX(item_revision_id) FROM {versioncontrol_item_revisions} WHERE repo_id = '. $repo_id));
+    db_query("COMMIT");
     if ($start != $end) {
       watchdog('vc_git', "Concurrency error during inital import of {versioncontrol_item_revisions} for repo id #$repo_id. Expected $start, got $end. Recovering.");
       $logs[0]->name_block->history = array();
@@ -187,8 +191,9 @@ $autoinc_step = variable_get('versioncontrol_git_autoincrement_step', 1);
     if ($values) {
       $query->execute();
     }
+    
 
-
+    db_query("BEGIN");
     //db_query('LOCK TABLES {versioncontrol_labels} WRITE');
     $values = '';
     $start = db_result(db_query('SELECT MAX(label_id) FROM {versioncontrol_labels}'));
@@ -213,6 +218,7 @@ $autoinc_step = variable_get('versioncontrol_git_autoincrement_step', 1);
       $query->execute();
     }
     $end = db_result(db_query('SELECT MAX(label_id) FROM {versioncontrol_labels} WHERE repo_id = '. $repo_id));
+    db_query("COMMIT");
     if ($start != $end) {
       watchdog('vc_git', "Concurrency error during inital import of {versioncontrol_labels} for repo id #$repo_id. Expected $start, got $end. Recovering.");
       $result = db_query("SELECT label_id, name FROM {versioncontrol_labels} WHERE repo_id = $repo_id ORDER BY label_id ASC");