diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/README.md b/streampark-console/streampark-console-service/src/main/assembly/script/README.md
index 0191fe1411..8b79cbf049 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/README.md
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/README.md
@@ -5,7 +5,8 @@
 Currently, StreamPark supports MySQL and PostgreSQL. The schema directory is the current database schema, it includes mysql and pgsql
 schema. The data directory is the current complete data, it includes mysql and pgsql data.
 
-If you use MySQL as the StreamPark database, please execute `mysql-schema.sql` first, then execute `mysql-data.sql` to initialize data.
+If you use MySQL as the StreamPark database, please create a database named `streampark` first execute "create database if not exists `streampark` character set utf8mb4 collate utf8mb4_general_ci"
+then under the database `streampark` execute `mysql-schema.sql`, then execute `mysql-data.sql` to initialize data.
 
 If you use PostgreSQL as the StreamPark database, please execute `pgsql-schema.sql` first, then execute `pgsql-data.sql` to initialize data.
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql b/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
index 2e87336901..6e734712c7 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/data/mysql-data.sql
@@ -15,8 +15,6 @@
  * limitations under the License.
  */
 
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql b/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
index db29202ced..75495a46f6 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql
@@ -15,9 +15,6 @@
  * limitations under the License.
  */
 
-create database if not exists `streampark` character set utf8mb4 collate utf8mb4_general_ci;
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/1.2.3.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/1.2.3.sql
index 1582e433ed..2e96d6ec98 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/1.2.3.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/1.2.3.sql
@@ -15,8 +15,6 @@
  * limitations under the License.
  */
 
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql
index 19f15c213d..f90b309188 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.0.0.sql
@@ -15,8 +15,6 @@
  * limitations under the License.
  */
 
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql
index e09ce96bab..711c2608f9 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.0.sql
@@ -15,8 +15,6 @@
  * limitations under the License.
  */
 
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.2.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.2.sql
index c0fafc6417..4ed20e5fec 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.2.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.2.sql
@@ -15,8 +15,6 @@
  * limitations under the License.
  */
 
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.3.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.3.sql
index b942363dbe..98b6ca5a9a 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.3.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.1.3.sql
@@ -15,8 +15,6 @@
  * limitations under the License.
  */
 
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
diff --git a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
index ba95f45fa5..0902a6b6b1 100644
--- a/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
+++ b/streampark-console/streampark-console-service/src/main/assembly/script/upgrade/mysql/2.2.0.sql
@@ -15,12 +15,9 @@
  * limitations under the License.
  */
 
-use streampark;
-
 set names utf8mb4;
 set foreign_key_checks = 0;
 
-
 -- ----------------------------
 -- Table structure for t_app
 -- ----------------------------