diff --git a/lib/mysql.js b/lib/mysql.js
index 3ea0c82..1f0a466 100644
--- a/lib/mysql.js
+++ b/lib/mysql.js
@@ -56,11 +56,11 @@ exports.insert = function (dbname, index, values) {
     for (let db in insertValues) {
         if (db === 'ts_counter') {
             while (insertValues[db].length) {
-                query += `INSERT INTO \`${dbname}\`.ts_counter (id, ts, val) VALUES ${insertValues[db].splice(0, 500).join(',')};`;
+                query += `INSERT IGNORE INTO \`${dbname}\`.ts_counter (id, ts, val) VALUES ${insertValues[db].splice(0, 1000).join(',')};\n`;
             }
         } else {
             while (insertValues[db].length) {
-                query += `INSERT INTO \`${dbname}\`.${db} (id, ts, val, ack, _from, q) VALUES ${insertValues[db].splice(0, 500).join(',')};`;
+                query += `INSERT IGNORE INTO \`${dbname}\`.${db} (id, ts, val, ack, _from, q) VALUES ${insertValues[db].splice(0, 1000).join(',')};\n`;
             }
         }
     }
@@ -88,11 +88,11 @@ exports.getIdSelect = function (dbname, name) {
 };
 
 exports.getIdInsert = function (dbname, name, type) {
-    return  `INSERT INTO \`${dbname}\`.datapoints (name, type) VALUES('${name}', ${type});`;
+    return  `INSERT IGNORE INTO \`${dbname}\`.datapoints (name, type) VALUES('${name}', ${type});`;
 };
 
 exports.getIdUpdate = function (dbname, id, type) {
-    return  `UPDATE \`${dbname}\`.datapoints SET type=${type} WHERE id=${id};`;
+    return  `UPDATE IGNORE \`${dbname}\`.datapoints SET type=${type} WHERE id=${id};`;
 };
 
 exports.getFromSelect = function (dbname, from) {
@@ -104,7 +104,7 @@ exports.getFromSelect = function (dbname, from) {
 };
 
 exports.getFromInsert = function (dbname, from) {
-    return `INSERT INTO \`${dbname}\`.sources (name) VALUES('${from}');`;
+    return `INSERT IGNORE INTO \`${dbname}\`.sources (name) VALUES('${from}');`;
 };
 
 exports.getCounterDiff = function (dbname, options) {