diff --git a/scheduler/app/database/__init__.py b/scheduler/app/database/__init__.py
index 50ba88a..d12cfaa 100644
--- a/scheduler/app/database/__init__.py
+++ b/scheduler/app/database/__init__.py
@@ -11,12 +11,15 @@
 DB_PASSWD = os.getenv("DB_PASSWD")
 db_user = ""
 db_passwd = ""
-if DB_USER:
+if DB_ROOT_USER and DB_ROOT_PASSWD:
+    db_user = "root"
+    db_passwd = DB_ROOT_PASSWD
+elif DB_USER and DB_PASSWD:
     db_user = DB_USER
     db_passwd = DB_PASSWD
 else:
     db_user = "root"
-    db_passwd = DB_ROOT_PASSWD
+    db_passwd = ""
 
 DB_HOST = os.getenv("DB_HOST", "seatable-mysql")
 DB_PORT = os.getenv("DB_PORT", "3306")
diff --git a/scheduler/app/database/init_db.py b/scheduler/app/database/init_db.py
index aae7577..91d0f9b 100755
--- a/scheduler/app/database/init_db.py
+++ b/scheduler/app/database/init_db.py
@@ -9,12 +9,15 @@
 DB_PASSWD = os.getenv("DB_PASSWD")
 db_user = ""
 db_passwd = ""
-if DB_USER:
+if DB_ROOT_USER and DB_ROOT_PASSWD:
+    db_user = "root"
+    db_passwd = DB_ROOT_PASSWD
+elif DB_USER and DB_PASSWD:
     db_user = DB_USER
     db_passwd = DB_PASSWD
 else:
     db_user = "root"
-    db_passwd = DB_ROOT_PASSWD
+    db_passwd = ""
 
 DB_HOST = os.getenv("DB_HOST", "seatable-mysql")
 DB_PORT = int(os.getenv("DB_PORT", "3306"))
@@ -36,54 +39,20 @@ def wait_for_mysql():
         return
 
 
-def check_and_create_mysql_user():
-    connection = pymysql.connect(
-        host=DB_HOST, port=DB_PORT, user=DB_ROOT_USER, passwd=DB_ROOT_PASSWD
-    )
-
-    try:
-        with connection.cursor() as cursor:
-            if db_user != "root":
-                query_user_exists = f"SELECT EXISTS(SELECT 1 FROM mysql.user WHERE User='{db_user}' AND Host='%') AS user_exists;"
-                cursor.execute(query_user_exists)
-                result = cursor.fetchone()
-                user_exists = result[0] == 1
-                if not user_exists:
-                    create_user_sql = (
-                        f"CREATE USER '{db_user}'@'%' IDENTIFIED BY '{db_passwd}';"
-                    )
-                    cursor.execute(create_user_sql)
-                    print(f"Create user '{db_user}'@'%' sucessfully.")
-
-                grant_privileges_sql = (
-                    f"GRANT ALL PRIVILEGES ON {DATABASE_NAME}.* TO '{db_user}'@'%';"
-                )
-                for stmt in grant_privileges_sql.split(";"):
-                    if stmt.strip():
-                        cursor.execute(stmt)
-                print(f"Granted user '{db_user}'@'%' privileges sucessfully.")
-
-                cursor.execute("FLUSH PRIVILEGES;")
-    finally:
-        connection.close()
-
-
 wait_for_mysql()
 
-sql = 'mysql -h %s -u%s -p%s -e "CREATE DATABASE IF NOT EXISTS %s;"' % (
-    shlex.quote(DB_HOST),
-    shlex.quote(DB_ROOT_USER),
-    shlex.quote(DB_ROOT_PASSWD),
-    DATABASE_NAME,
-)
-os.system(sql)
-
-check_and_create_mysql_user()
-
+if db_user == "root":
+    sql = 'mysql -h %s -u%s -p%s -e "CREATE DATABASE IF NOT EXISTS %s;"' % (
+        shlex.quote(DB_HOST),
+        shlex.quote(db_user),
+        shlex.quote(db_passwd),
+        DATABASE_NAME,
+    )
+    os.system(sql)
 sql = "mysql -h %s -u%s -p%s %s </opt/scheduler/database/initial_tables.sql" % (
     shlex.quote(DB_HOST),
-    shlex.quote(DB_ROOT_USER),
-    shlex.quote(DB_ROOT_PASSWD),
+    shlex.quote(db_user),
+    shlex.quote(db_passwd),
     DATABASE_NAME,
 )
 os.system(sql)
diff --git a/scheduler/app/upgrade/upgrade.py b/scheduler/app/upgrade/upgrade.py
index 0a30335..1b0cc00 100755
--- a/scheduler/app/upgrade/upgrade.py
+++ b/scheduler/app/upgrade/upgrade.py
@@ -23,12 +23,15 @@
 DB_PASSWD = os.getenv("DB_PASSWD")
 db_user = ""
 db_passwd = ""
-if DB_USER:
+if DB_ROOT_USER and DB_ROOT_PASSWD:
+    db_user = "root"
+    db_passwd = DB_ROOT_PASSWD
+elif DB_USER and DB_PASSWD:
     db_user = DB_USER
     db_passwd = DB_PASSWD
 else:
     db_user = "root"
-    db_passwd = DB_ROOT_PASSWD
+    db_passwd = ""
 
 DB_HOST = os.getenv("DB_HOST", "seatable-mysql")
 DB_PORT = os.getenv("DB_PORT", "3306")