sqlserver数据导入mysql二: 根据sqlserver表结构创建mysql表的perl代码

#!/usr/bin/perl
use DBI;
use Switch;
use Encode;
use Encode::CN;

my $source_name = "mysqldata";
my $source_user_name = "sa";
my $source_user_psd = "123";

my $db_name="sqldata";
my $location="192.168.0.208";
my $port="3306";
my $db_user="sa";
my $db_pass="123";

my $dbh=DBI->connect("dbi:ODBC:$source_name",$source_user_name,$source_user_psd);
#获取所有的用户表
my $sth=$dbh->prepare("select name,object_id from sys.all_objects where type='U' and is_ms_shipped=0 and name <>'sysdiagrams'");
$sth->execute();
my $n=0;
while (@data=$sth->fetchrow_array())
{
#print $data[0].$data[1];
$n+=1;

#获取列
get_columns($data[0],$data[1]);
open(FILE,">>createtableallname.txt");
syswrite(FILE,"$n\n");
syswrite(FILE,"$data[0]\n");
close(FILE);
}
$sth->finish;
$dbh ->disconnect;

##获取所有的列
sub get_columns
{
$dbh2=DBI->connect("dbi:ODBC:$source_name",$source_user_name,$source_user_psd);
my $sql="select col.name,tp.name,col.max_length,col.[precision],col.[scale],col.[is_nullable],col.[is_identity] from sys.all_columns col
inner join sys.types tp on col.system_type_id=tp.system_type_id  and col.user_type_id=tp.user_type_id
where object_id=$_[1]";

my $cols=$dbh2 -> prepare($sql);
$cols->execute();
my $cols_str = "";

my $n=0;
my $varlen=2000;
while(@col= $cols->fetchrow_array())
{

($col_name,$type_name,$max_length,$precision,$scale,$is_nullable,$is_identity)=@col;
switch ( $type_name)
{
case "nchar"  { $type_name="char"; }
case "bit"  { $type_name="boolean"; }
case "ntext"  { $type_name="text"; }
case "nvarchar"  { $type_name="varchar"; }
case "datetime2" { $type_name="date";}
case "money" { $type_name="decimal";}
else { $type_name=$type_name;}
}
if($type_name eq "varchar")
{

$n++;
}
if($n==0)
{$n=1}
$varlen=21000/$n;
}
my $cols2=$dbh2 -> prepare($sql);
$cols2->execute();
while(@col= $cols2->fetchrow_array())
{
($col_name,$type_name,$max_length,$precision,$scale,$is_nullable,$is_identity)=@col;
switch ( $type_name)
{
case "nchar"  { $type_name="char"; }
case "bit"  { $type_name="boolean"; }
case "ntext"  { $type_name="text"; }
case "nvarchar"  { $type_name="varchar"; }
case "datetime2" { $type_name="date";}
case "money" { $type_name="decimal";}
else { $type_name=$type_name;}
}
if($cols_str ne "")
{
$cols_str = "$cols_str, \n";
}
if($type_name eq "hierarchyid")
{
if($cols_str eq "")
{
#				$cols_str = "$cols_str `id` INT NOT NULL AUTO_INCREMENT PRIMARY KEY,`parent_id` INT";
$cols_str = "$cols_str `$col_name` varchar(31)";
}
else
{
$cols_str = "$cols_str `$col_name`varchar(31)";
}
}
else
{
$cols_str = "$cols_str `$col_name` $type_name";
switch($type_name)
{
case "varchar"
{
if($max_length == -1)
{
$cols_str = "$cols_str($varlen)";
}
else
{
#$cols_str = "$cols_str(985)";
$cols_str = "$cols_str($max_length)";
}
}
case "numeric"
{
$cols_str = "$cols_str($precision,$scale)";
}
case "char"
{
if($max_length == -1)
{
$cols_str = "$cols_str($varlen)";
}
else
{
#$cols_str = "$cols_str(985)";
$cols_str = "$cols_str($max_length)";
}
}

}
if($is_nullable == 0)
{
$cols_str="$cols_str NOT NULL ";
}
if($is_identity == 1)
{
$cols_str="$cols_str AUTO_INCREMENT PRIMARY KEY";
}
}
}
#print "create table IF NOT EXISTS `$_[0]`($cols_str);";
exec_mysql( "create table IF NOT EXISTS `$_[0]`($cols_str);");
$cols->finish;
$cols2->finish;
$dbh2 ->disconnect;

}

sub exec_mysql
{

my $data_base = "DBI:mysql:$db_name:$location:$port";

my $dbh3=DBI -> connect($data_base,$db_user,$db_pass);

$dbh3->do("SET character_set_client = 'utf8'");
$dbh3->do("SET character_set_connection = 'utf8'");
# my	 $data_str=encode("utf-8",decode("gbk",$_[0]));
my $data_str=$_[0];

my $sth=$dbh3->prepare($data_str);

#open(FILE,">>createtableallname.txt");
#syswrite(FILE,"$data_str");
#close(FILE);

$sth->execute() or die "$data_str----ERROR::$data_str::$dbh3->errstr";
$dbh3->disconnect;
print 'ok';
}