diff --git a/tinylinks/management/commands/import_yourls_db.py b/tinylinks/management/commands/import_yourls_db.py
index ec3a71f..fbae231 100644
--- a/tinylinks/management/commands/import_yourls_db.py
+++ b/tinylinks/management/commands/import_yourls_db.py
@@ -4,41 +4,41 @@
 
 import mysql.connector
 from django.core.management.base import BaseCommand
-from tinylinks.management.commands import _config, _queries
+from tinylinks.management.commands import _config
 from tinylinks.models import Tinylink, TinylinkLog
 
 
-TINYLINK_QUERY = "SELECT url, keyword FROM yourls_url LIMIT %s, %s;"
-TINYLINKLOG_QUERY = "SELECT referrer, user_agent, ip_address, click_time FROM yourls_log LIMIT %s, %s;"
+TINYLINK_QUERY = "SELECT url, keyword FROM yourls_url WHERE id > %s LIMIT %s, %s;"
+TINYLINKLOG_QUERY = "SELECT referrer, user_agent, ip_address, click_time FROM yourls_log WHERE id > %s LIMIT %s, %s;"
 
 
 class Command(BaseCommand):
-    def get_tinylinks_query_data(self, start) -> List[tuple]:
+    def get_tinylinks_query_data(self, start_id, offset) -> List[tuple]:
         cnx = mysql.connector.connect(**_config.config)
         cursor = cnx.cursor()
-        cursor.execute(TINYLINK_QUERY, (start, self.chunk_length))
+        cursor.execute(TINYLINK_QUERY, (start_id, self.chunk_length, offset))
         data = [(long_url.decode('utf-8'), short_url) for (long_url, short_url) in cursor]
         cnx.close()
         cursor.close()
         return data
 
     def insert_tinylinks(self):
-        start = 0
-        data = self.get_tinylinks_query_data(start)
+        offset = self.offset
+        data = self.get_tinylinks_query_data(self.start_id, offset)
         while data:
-            print("Processing rows from {} to {}".format(start, start + self.chunk_length))
+            print("Processing rows from {} to {}".format(offset, offset + self.chunk_length))
             tinylinks_to_add = [
                 Tinylink(long_url=long_url, short_url=shorturl)
                 for long_url, shorturl in data
             ]
             Tinylink.objects.bulk_create(tinylinks_to_add)
-            start += self.chunk_length
-            data = self.get_tinylinks_query_data(start)
+            offset += self.chunk_length
+            data = self.get_tinylinks_query_data(self.start_id, offset)
 
-    def get_tinylinks_logs_query_data(self, start) -> List[tuple]:
+    def get_tinylinks_logs_query_data(self, start_id, offset) -> List[tuple]:
         cnx = mysql.connector.connect(**_config.config)
         cursor = cnx.cursor()
-        cursor.execute(TINYLINKLOG_QUERY, (start, self.chunk_length))
+        cursor.execute(TINYLINKLOG_QUERY, (start_id, self.chunk_length, offset))
         data = [
             (referrer, user_agent, ip_address, click_time)
             for (referrer, user_agent, ip_address, click_time) in cursor
@@ -48,11 +48,11 @@ def get_tinylinks_logs_query_data(self, start) -> List[tuple]:
         return data
 
     def insert_tinylinks_logs(self):
-        start = 0
-        data = self.get_tinylinks_logs_query_data(start)
+        offset = self.offset
+        data = self.get_tinylinks_logs_query_data(self.start_id, offset)
         while data:
-            print("Processing rows from {} to {}".format(start,
-                                                         start + self.chunk_length))
+            print("Processing rows from {} to {}".format(offset,
+                                                         offset + self.chunk_length))
             tinylinks_logs_to_add = [
                 TinylinkLog(
                     referrer=referrer,
@@ -63,14 +63,16 @@ def insert_tinylinks_logs(self):
                 for referrer, user_agent, remote_ip, datetime in data
             ]
             TinylinkLog.objects.bulk_create(tinylinks_logs_to_add)
-            start += self.chunk_length
-            data = self.get_tinylinks_logs_query_data(start)
+            offset += self.chunk_length
+            data = self.get_tinylinks_logs_query_data(self.start_id, offset)
 
     def add_arguments(self, parser):
-        parser.add_argument("username", nargs=1, type=str)
-        parser.add_argument("password", nargs=1, type=str)
-        parser.add_argument("dbname", nargs=1, type=str)
-        parser.add_argument("chunk-length", nargs="?", type=int, default=100)
+        parser.add_argument("username", nargs=1, type=str, help="Database username")
+        parser.add_argument("password", nargs=1, type=str, help="Database user password")
+        parser.add_argument("dbname", nargs=1, type=str, help="Database name")
+        parser.add_argument("offset", nargs="?", type=int, default=0, help="The offset of processing rows")
+        parser.add_argument("start-id", nargs="?", type=int, default=0, help="The starting id of imported rows")
+        parser.add_argument("chunk-length", nargs="?", type=int, default=100, help="The chunk length")
 
     def handle(self, *args, **options):
         _config.set_configs(
@@ -78,6 +80,8 @@ def handle(self, *args, **options):
             password=options["password"][0],
             database=options["dbname"][0],
         )
+        self.offset = options.get("offset")
+        self.start_id = options.get("start-id")
         self.chunk_length = options.get("chunk-length")
         self.insert_tinylinks()
         self.insert_tinylinks_logs()