修改环境变量之后运行 init_sql.sh 来初始化数据库。

4.1.2 直接运行初始化 SQL

init_sql.sh 初始化数据库的脚本核心是执行 seatunnel_server_mysql.sql：

workDir=`dirname $0`

workDir=`cd ${ workDir};pwd`

source ${workDir}/seatunnel_server_env.sh

usage="Usage: seatunnel_server_env.sh must contain hostname/port/username/password."code>

if [[ ! -n "${ HOSTNAME}" ]] || [[ ! -n "${PORT}" ]] || [[ ! -n "${USERNAME}" ]] || [[ ! -n "${PASSWORD}" ]]; then

echo $usage

exit 1

fi

mysql -h${ HOSTNAME} -P${PORT} -u${USERNAME} -p${PASSWORD} < ${workDir}/seatunnel_server_mysql.sql

所以你也可以直接选择跳过 init_sql.sh 初始化数据库的脚本来执行 seatunnel_server_mysql.sql。例如，你可以使用 Navicat 导入执行：

导入执行完后创建的表如下所示：

4.2 修改端口与数据源

修改 <code>conf/application.yml 配置文件来修改端口号以及 Web 访问数据库的数据源信息：

server:

port: 8801

spring:

application:

name: seatunnel

jackson:

date-format: yyyy-MM-dd HH:mm:ss

datasource:

driver-class-name: com.mysql.cj.jdbc.Driver

url: jdbc:mysql://localhost:3306/seatunnel?useSSL=false&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&allowPublicKeyRetrieval=true

username: root

password: root

mvc:

pathmatch:

matching-strategy: ant_path_matcher

4.3 配置引擎服务信息

复制引擎服务中配置文件到 Web 配置目录下面。将 hazelcast-client 配置文件拷贝到 Web 的 conf 目录下：

cp /opt/seatunnel/config/hazelcast-client.yaml /opt/seatunnel-web/conf/

将插件配置文件拷贝到 Web 的 conf 目录下：

cp /opt/seatunnel/connectors/plugin-mapping.properties /opt/seatunnel-web/conf/

4.4 配置 MySQL 驱动

在这我们选择 MySQL 作为元数据库，需要对应的驱动包放到 libs 下：

cp mysql-connector-java-8.0.16.jar /opt/seatunnel-web/libs/

4.5 配置数据源JAR包

下载 SeaTunnel Web 的源码，将 download_datasource.sh 拷贝到 script 目录下：

cp apache-seatunnel-web-1.0.1-src/seatunnel-server/seatunnel-app/src/main/bin/download_datasource.sh /opt/seatunnel-web/script/

根据你的需要选择需要下载的数据源，如果不下载在 Web 中配置数据源时会提示没有可用的数据源：

# get seatunnel web home

SEATUNNEL_WEB_HOME=$(cd $(dirname $0);cd ../;pwd)

DATASOURCE_DIR=${SEATUNNEL_WEB_HOME}/datasource

# If you don’t want to download a certain data source, you can delete the element below

datasource_list=(

"datasource-plugins-api"

"datasource-elasticsearch"

"datasource-hive"

"datasource-jdbc-clickhouse"

"datasource-jdbc-hive"

"datasource-jdbc-mysql"

"datasource-jdbc-postgresql"

"datasource-jdbc-starrocks"

"datasource-jdbc-tidb"

"datasource-kafka"

"datasource-mysql-cdc"

"datasource-starrocks"

"datasource-mongodb"

)

默认是从 mvvm 下载，可能下载速度很慢，我这边安装了 Maven 并且配置了阿里云仓库，因此将脚本中的 mvvm 命令替换为 mvn 命令改从 maven 中下载：

for i in "${datasource_list[@]}"

do

echo "$i"

echo "Downloading datasource: " "$i"

/opt/maven/bin/mvn dependency:get -DgroupId=org.apache.seatunnel -DartifactId="$i" -Dversion="$version" -Ddest="$DATASOURCE_DIR"code>

done

“$SEATUNNEL_WEB_HOME”/mvnw -> /opt/maven/bin/mvn