Perl访问MSSQL并迁移到MySQL数据库脚本实例

一、准备工作

在进行Perl访问MSSQL并迁移到MySQL数据库脚本实例之前，需要进行一些准备工作，具体如下：

1. 安装Perl、DBI、DBD::ODBC模块

在开发环境中，需要安装Perl语言环境，并通过Perl模块管理器（如cpanm、ppm）安装DBI和DBD::ODBC模块。

1. 安装Microsoft ODBC驱动程序

在连接MSSQL数据库时，需要安装Microsoft ODBC驱动程序，建议安装ODBC Driver for SQL Server。下载地址：https://www.microsoft.com/en-us/sql-server/developer-get-started/perl/windows/

1. 安装MySQL数据库

在迁移数据到MySQL时，需要在服务器上安装MySQL数据库。

二、连接MSSQL数据库

在Perl中，通过DBD::ODBC模块来连接MSSQL数据库，首先需要定义连接字符串，示例代码如下：

my $mssql_dsn = "dbi:ODBC:Driver={ODBC Driver 17 for SQL Server};Server={hostname};Database={database}";
my $mssql_user = "{user}";
my $mssql_pass = "{password}";

my $dbh = DBI->connect($mssql_dsn, $mssql_user, $mssql_pass) or die $DBI::errstr;

其中，$mssql_dsn为连接字符串，其中包含ODBC Driver名称、服务器名称、数据库名称等信息。$mssql_user和$mssql_pass是数据库的登录用户名和密码。

连接成功后，可以通过$dbh来执行SQL语句，具体代码如下：

my $sth = $dbh->prepare("SELECT * FROM {table}");
$sth->execute();

while (my $row = $sth->fetchrow_hashref()) {
    # 处理每一行数据
}

$sth->finish();
$dbh->disconnect();

该代码用于获取表中的所有数据并进行处理。

三、迁移数据到MySQL

在连接成功并获取到MSSQL数据库中的数据后，需要将数据导出并迁移到MySQL数据库中。具体步骤如下：

1. 定义MySQL连接字符串

my $mysql_dsn = "dbi:mysql:{database}:{hostname}:3306";
my $mysql_user = "{user}";
my $mysql_pass = "{password}";

my $mysql_dbh = DBI->connect($mysql_dsn, $mysql_user, $mysql_pass) or die $DBI::errstr;

其中，$mysql_dsn为连接字符串，其中包含数据库名称、服务器名称、端口等信息。$mysql_user和$mysql_pass是数据库的登录用户名和密码。

1. 导出数据到CSV文件

my $sth = $dbh->prepare("SELECT * FROM {table}");
$sth->execute();

my $csv = Text::CSV->new({ binary => 1, sep_char => ',' });
open my $fh, ">:encoding(utf8)", "{file_name}.csv" or die "$file_name.csv: $!";
$csv->print($fh, [qw{col1 col2 col3}]); # 打印CSV文件头

while (my $row = $sth->fetchrow_hashref()) {
    $csv->print($fh, [$row->{col1}, $row->{col2}, $row->{col3}]); # 打印每一行数据到CSV文件
}

close $fh;
$sth->finish();

该代码用于将表中的数据导出到CSV文件中，其中包含CSV文件头和每一行数据。

1. 导入数据到MySQL数据库

my $sth = $mysql_dbh->prepare("LOAD DATA LOCAL INFILE '{file_name}.csv' INTO TABLE {table} FIELDS TERMINATED BY ',' ENCLOSED BY '\"' LINES TERMINATED BY '\\n' IGNORE 1 ROWS") or die $DBI::errstr;
$sth->execute();

$sth->finish();
$mysql_dbh->disconnect();

该代码用于将CSV文件中的数据导入到MySQL数据库中，其中需要指定CSV文件的路径、表名、分隔符、行结束符等信息。数据导入完成后，需要关闭MySQL连接。

四、示例说明

1. 导出MSSQL数据并迁移到MySQL

# 定义MSSQL连接字符串
my $mssql_dsn = "dbi:ODBC:Driver={ODBC Driver 17 for SQL Server};Server={mssql_host};Database={database}";
my $mssql_user = "{user}";
my $mssql_pass = "{password}";

# 定义MySQL连接字符串
my $mysql_dsn = "dbi:mysql:{database}:{mysql_host}:3306";
my $mysql_user = "{user}";
my $mysql_pass = "{password}";

# 连接MSSQL数据库
my $mssql_dbh = DBI->connect($mssql_dsn, $mssql_user, $mssql_pass) or die $DBI::errstr;

# 获取表中的数据并导出到CSV文件
my $sth = $mssql_dbh->prepare("SELECT * FROM {table}");
$sth->execute();

my $csv = Text::CSV->new({ binary => 1, sep_char => ',' });
open my $fh, ">:encoding(utf8)", "{file_name}.csv" or die "$file_name.csv: $!";
$csv->print($fh, [qw{col1 col2 col3}]); # 打印CSV文件头

while (my $row = $sth->fetchrow_hashref()) {
    $csv->print($fh, [$row->{col1}, $row->{col2}, $row->{col3}]); # 打印每一行数据到CSV文件
}

close $fh;
$sth->finish();
$mssql_dbh->disconnect();

# 连接MySQL数据库
my $mysql_dbh = DBI->connect($mysql_dsn, $mysql_user, $mysql_pass) or die $DBI::errstr;

# 将CSV文件中的数据导入到MySQL数据库中
$sth = $mysql_dbh->prepare("LOAD DATA LOCAL INFILE '{file_name}.csv' INTO TABLE {table} FIELDS TERMINATED BY ',' ENCLOSED BY '\"' LINES TERMINATED BY '\\n' IGNORE 1 ROWS") or die $DBI::errstr;
$sth->execute();

$sth->finish();
$mysql_dbh->disconnect();

该代码用于连接MSSQL和MySQL数据库，获取MSSQL数据库的数据并导出到CSV文件中，接着将CSV文件中的数据导入到MySQL数据库中。

1. 查询MSSQL数据库中的数据

# 定义连接字符串
my $mssql_dsn = "dbi:ODBC:Driver={ODBC Driver 17 for SQL Server};Server={mssql_host};Database={database}";
my $mssql_user = "{user}";
my $mssql_pass = "{password}";

# 连接MSSQL数据库
my $dbh = DBI->connect($mssql_dsn, $mssql_user, $mssql_pass) or die $DBI::errstr;

# 查询表中所有数据并输出
my $sth = $dbh->prepare("SELECT * FROM {table}");
$sth->execute();

while (my $row = $sth->fetchrow_hashref()) {
    print "$row->{col1}, $row->{col2}, $row->{col3}\n";
}

$sth->finish();
$dbh->disconnect();

该代码用于连接MSSQL数据库，查询指定表的所有数据并输出。