国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Perl > 正文

Perl訪問MSSQL并遷移到MySQL數據庫腳本實例

2020-06-04 20:31:07
字體:
來源:轉載
供稿:網友

Linux下沒有專門為MSSQL設計的訪問庫,不過介于MSSQL本是從sybase派生出來的,因此用來訪問Sybase的庫自然也能訪問MSSQL,FreeTDS就是這么一個實現。
Perl中通常使用DBI來訪問數據庫,因此在系統安裝了FreeTDS之后,可以使用DBI來通過FreeTDS來訪問MSSQL數據庫,例子:
代碼如下:
using DBI;
my $cs = "DRIVER={FreeTDS};SERVER=主機;PORT=1433;DATABASE=數據庫;UID=sa;PWD=密碼;TDS_VERSION=7.1;charset=gb2312";
my $dbh = DBI->connect("dbi:ODBC:$cs") or die $@;
因為本人不怎么用windows,為了研究QQ群數據庫,需要將數據從MSSQL中遷移到MySQL中,特地為了QQ群數據庫安裝了一個Windows Server 2008和SQL Server 2008r2,不過過幾天評估就到期了,研究過MySQL的Workbench有從MS SQL Server遷移數據的能力,不過對于QQ群這種巨大數據而且分表分庫的數據來說顯得太麻煩,因此寫了一個通用的perl腳本,用來將數據庫從MSSQL到MySQL遷移,結合bash,很方便的將這二十多個庫上百張表給轉移過去了,Perl代碼如下:
代碼如下:
#!/usr/bin/perl
use strict;
use warnings;
use DBI;


die "Usage: qq db/n" if @ARGV != 1;
my $db = $ARGV[0];

print "Connectin to databases $db.../n";
my $cs = "DRIVER={FreeTDS};SERVER=MSSQL的服務器;PORT=1433;DATABASE=$db;UID=sa;PWD=MSSQL密碼;TDS_VERSION=7.1;charset=gb2312";

sub db_connect
{
    my $src = DBI->connect("dbi:ODBC:$cs") or die $@;
    my $target = DBI->connect("dbi:mysql:host=MySQL服務器", "MySQL用戶名", "MySQL密碼") or die $@;
    return ($src, $target);
}
my ($src, $target) = db_connect;

print "Reading table schemas..../n";

my $q_tables = $src->prepare("SELECT name FROM sysobjects WHERE xtype = 'U' AND name != 'dtproperties';");#獲取所有表名
my $q_key_usage = $src->prepare("SELECT TABLE_NAME, COLUMN_NAME from INFORMATION_SCHEMA.KEY_COLUMN_USAGE;");#獲取表的主鍵
$q_tables->execute;
my @tables = ();
my %keys = ();
push @tables, @_ while @_ = $q_tables->fetchrow_array;

$q_tables->finish;

$q_key_usage->execute();
$keys{$_[0]} = $_[1] while @_ = $q_key_usage->fetchrow_array;
$q_key_usage->finish;


#獲取表的索引信息
my $q_index = $src->prepare(qq(
    SELECT T.name, C.name
    FROM sys.index_columns I
    INNER JOIN sys.tables T ON T.object_id = I.object_id
    INNER JOIN sys.columns C ON C.column_id = I.column_id AND I.object_id = C.object_id;
));
$q_index->execute;
my %table_indices = ();
while(my @row = $q_index->fetchrow_array)
{
    my ($table, $column) = @row;
    my $columns = $table_indices{$table};
    $columns = $table_indices{$table} = [] if not $columns;
    push @$columns, $column;
}
$q_index->finish;

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 忻州市| 启东市| 嘉荫县| 塔城市| 新邵县| 虎林市| 清镇市| 阿巴嘎旗| 郴州市| 高青县| 香河县| 喀喇沁旗| 望城县| 太原市| 车致| 泰兴市| 弋阳县| 白银市| 乃东县| 新兴县| 三亚市| 固安县| 康定县| 南汇区| 岚皋县| 泰顺县| 民乐县| 金山区| 门源| 济源市| 基隆市| 南京市| 松溪县| 麻城市| 攀枝花市| 安徽省| 汉沽区| 梓潼县| 镇雄县| 灌阳县| 绥芬河市|