微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

perl DBI 总结

分类：Perl作者：编程之家AI导航网
最近在写perl程序进行数据的采集，perl教程在网上少的可怜呐，至少我找到的资料是很少的。在连接数据库方面下面这个博客写的还是很清晰的，所以就转过来了。

源文地址：http://blog.csdn.net/like_zhz/article/details/5441946

DBI和DBD的不同关系模型：

DBI&DBD

##########################################################################
可移植的DBI方法：
connect 建立到一个数据库服务器的连接
disconnect 断开数据库服务器的连接
prepare 准备执行一个sql语句
execute 执行准备好的语句
do 准备并执行一个sql语句
quote 加引号于要插入的字符串或BLOB值
fetchrow_array 作为一个字段数组取出下一行
fetchrow_arrayref 作为一个字段的引用数组取出下一行
fetchrow_hashref 作为一个哈希表的引用取出下一行
fetchall_arrayref 作为一个字段数组取出所有数据
finish 完成一条语句并且让系统释放资源
rows 返回受影响的行数
data_sources 返回可在localhost上得到的数据库的数组
ChopBlanks 控制fetchrow_*方法是否剥去空格
NUM_OF_ParaMS 在准备的语句中的占位(placeholder-参数)的数目
NULLABLE 其列可以是NULL
trace 执行调试跟踪
##########################################################################
$dbh 数据库句柄
$sth 语句句柄
$rc 返回代码(经常是一个状态)
$rv 返回值(经常是一个行数)
##########################################################################
①connect($data_source,$username,$password)
使用connect方法使得一个数据库连接到数据源。$data_source值应该以DBI:driver_name:开始。以DBD::MysqL驱动程序使用connect的例子：
$dbh = DBI->connect("DBI:MysqL:$database",$user,$password);
$dbh = DBI->connect("DBI:MysqL:$database:$hostname",
$user,$password);
$dbh = DBI->connect("DBI:MysqL:$database:$hostname:$port",$password);

②disconnect
disconnect方法从数据库断开数据库句柄。它一般就在你从程序退出之前被调用。范例：
$rc = $dbh->disconnect;
prepare($statement)
准备一条由数据库引擎执行的sql语句并且返回语句句柄($sth)，你可以使用它调用execute方法。一般地你借助于prepare和execute来处理SELECT语句(和类SELECT语句，例如SHOW、DESCRIBE和EXPLAIN)。范例：
$sth = $dbh->prepare($statement)
or die "Can't prepare $statement: $dbh->errstr/n";
③execute
execute方法执行一个准备好的语句。对非SELECT语句，execute返回受影响的行数。如果没有行受影响，execute返回"0E0"，Perl将它视作零而不是真。对于SELECT语句，execute只是在数据库中启动SQL查询；你需要使用在下面描述的fetch_*方法之一检索数据。范例：
$rv = $sth->execute
or die "can't execute the query: $sth->errstr;
④do($statement)
do方法准备并且执行一条sql语句并且返回受影响的行数。如果没有行受到影响，do返回"0E0"，Perl将它视为零而不是真。这个方法通常用于事先无法准备好(由于驱动程序的限制)或不需要执行多次(插入、删除等等)的非SELECT语句。范例：
$rv = $dbh->do($statement)
or die "Can't execute $statement: $dbh- >errstr/n";
⑤quote($string)
quote方法被用来“转义”包含在string中的任何特殊字符并增加所需的外部的引号。范例：
$sql = $dbh->quote($string)
⑥fetchrow_array
这个方法取下一行数据并且作为一个字段值数组返回它。范例：
while(@row = $sth->fetchrow_array) {
print qw($row[0]/t$row[1]/t$row[2]/n);
}
⑦fetchrow_arrayref
这个方法取下一行数据并且作为一个对一个字段值数组的引用返回它。范例：
while($row_ref = $sth->fetchrow_arrayref) {
print qw($row_ref->[0]/t$row_ref->[1]/t$row_ref->[2]/n);
}
⑧fetchrow_hashref
这个方法取一行数据并且返回包含字段名/值对的一个哈希表的一个引用。这个方法不如使用上述数组引用那样有效。范例：
while($hash_ref = $sth->fetchrow_hashref) {
print qw($hash_ref->{firstname}/t$hash_ref->{lastname}/t/
$hash_ref- > title}/n);
}
⑨fetchall_arrayref
这个方法被用来获得从sql语句被返回的所有数据(行)。它返回一个数组的引用，该数组包含对每行的数组的引用。你用一个嵌套循环来存取或打印数据。范例：
my $table = $sth->fetchall_arrayref
or die "$sth->errstr/n";
my($i,$j);
for $i ( 0 .. $#{$table} ) {
for $j ( 0 .. $#{$table->[$i]} ) {
print "$table->[$i][$j]/t";
}
print "/n";
}
⑩finish
便名没有更多的数据将从这个语句句柄取出。你调用这个方法释放语句句柄和任何与它相关的系统资源。范例：
$rc = $sth->finish;
⑪rows
返回由最后一条命令改变(更新、删除等)的行数。这通常用在非SELECT的execute语句之后。范例：
$rv = $sth->rows;
⑫NULLABLE
返回一个对一个布尔值数组的引用；对数组的每个成员，一个TRUE值表示该列可以包含NULL值。范例：
$null_possible = $sth->{NULLABLE};
⑬NUM_OF_FIELDS
这个属性表明由一条SELECT或SHOW FIELDS语句返回的字段数目。你可以用它检查一条语句是否返回了结果：一个零值表明一个象INSERT、DELETE或UPDATE的非SELECT语句。范例：
$nr_of_fields = $sth->{NUM_OF_FIELDS};
⑭data_sources($driver_name)
这个方法返回一个数组，它包含在主机'localhost'上的MysqL服务器可得到的数据库名。范例：
@dbs = DBI->data_sources("MysqL");
⑮ChopBlanks
这个属性确定fetchrow_*方法是否将去掉返回值的头和尾的空白。范例：
$sth->{'ChopBlanks'} =1;
trace($trace_level)
　
⑯trace($trace_level,$trace_filename)
trace方法开启或关闭跟踪。当作为一个DBI类方法调用时，它影响对所有句柄的跟踪。当作为一个数据库或语句句柄方法调用时，它影响对给定句柄的跟踪(和句柄的未来子孙)。设置$trace_level为2以提供详细的踪迹信息，设置$trace_level为0以关闭跟踪。踪迹输出缺省地输出到标准错误输出。如果指定$trace_filename，文件以添加模式打开并且所有跟踪的句柄的手被写入该文件。范例：
DBI->trace(2); # trace everything
DBI->trace(2,"/tmp/dbi.out"); # trace everything to /tmp/dbi.out
$dth->trace(2); # trace this database handle
$sth->trace(2); # trace this statement handle
你也可以通过设置DBI_TRACE环境变量开启DBI跟踪。将它设置为等价于调用DBI->(value)的数字值，将它设置为等价于调用DBI->(2,value)的路径名。

以上是原文内容。

-----------------------------------------------------------------------------

    看了一上午perl，然后用了一下午的时间写了下面的采集(用的时间比较多，呵呵)，代码没有抽象，高手轻拍。这个采集百万数据从informix到oracle不到10秒钟。

复制代码
# !/usr/bin/perl

use  strict;
 use  DBI;
 use   Time :: localtime ;
 use  Data :: Dumper;
 use   Time :: Local ;
 use  Net :: FTP;

 my  ( $para );

 if ( @ARGV   !=   1 ){
    
     $para   =   2 ;
     print   " \$para = $para\n " ;
        
} else {

     $para   =   $ARGV [ 0 ];
     print   " \$para = $para\n " ;
    
}

 if ( $para < 2 ){

     print   " 请输入大于等于2的数字！！！\n " ;
     exit ;
    
}


 my   $npmdb_dbh   =  DBI -> connect ( " DBI:ODBC:npmdb " ,   " informix " , " ******* " , {raiseerror => 0 , PrintError => 0 });
 my   $gisdb_dbh   =  DBI -> connect ( " DBI:Oracle:gisdb " ,   " gis " , {raiseerror => 1 , AutoCommit => 0 });

 if ( ! $npmdb_dbh   ||   ! $gisdb_dbh )
{
     print " 数据库联接失败   \n " ;
}
 else
{
     $npmdb_dbh -> do ( " set isolation to dirty read " );    
               
     my   $sel_sql   =   "  select a.first_result,a.ne_id,
                                    NVL(CSTRAFFIC_CONV11,0),
                                    NVL(CSTRAFFIC_CONV22,
                                    NVL(CSTRAFFIC_CONV55,
                                    NVL(TSNBRASSNBRUUL,
                                    NVL(TSNBRASSNBRUDL,
                                    NVL(BRUUL,
                                    NVL(BRUDL,
                                    NVL(TDDMAXTCP,
                                    NVL(TDDMEANTCP,
                                    NVL(NBRERRBLOCKSRECEIVEDCS_CONV55,
                                    NVL(NBRBLOCKSRECEIVEDCS_CONV55,
                                    NVL(NBRERRBLOCKSRECEIVEDPS,
                                    NVL(NBRBLOCKSRECEIVEDPS,
                                    NVL(SUCCMACDESTAB,
                                    NVL(SUCCRBESTAB,
                                    NVL(ATTMACDESTAB,
                                    NVL(ATTRBESTAB,
                                    NVL(a.ATTRABASSIGnesTABCS_CONV11,0)+NVL(a.ATTRABASSIGnesTABCS_CONV22,
                                    NVL(a.SUCCRABASSIGnesTABCS_CONV11,0)+NVL(a.SUCCRABASSIGnesTABCS_CONV22,
                                    NVL(a.ATTCONnesTAB_1,0)+NVL(a.ATTCONnesTAB_6,
                                    NVL(a.SUCCCONnesTAB_1,0)+NVL(a.SUCCCONnesTAB_6,0) ,
                                    round(NVL(SFB_DIVFLOAT_1(NVL(a.SUCCCONnesTAB_1,NVL(a.ATTCONnesTAB_1,0)*SFB_DIVFLOAT_1(NVL(a.SUCCRABASSIGnesTABCS_CONV11,NVL(a.ATTRABASSIGnesTABCS_CONV11,0)*100,2),
                                    NVL(a.ATTRABASSIGnesTABCS_CONV55,
                                    NVL(a.SUCCRABASSIGnesTABCS_CONV55,0)*SFB_DIVFLOAT_1(NVL(a.SUCCRABASSIGnesTABCS_CONV55,NVL(a.ATTRABASSIGnesTABCS_CONV55,
                                    NVL(a.ATTCONnesTAB,
                                    NVL(a.SUCCCONnesTAB,
                                    NVL(a.ATTRABASSIGnesTABPS,
                                    NVL(a.SUCCRABASSIGnesTABPS,
                                    round(NVL(SFB_DIVFLOAT_1(a.SUCCRABASSIGnesTABPS,a.ATTRABASSIGnesTABPS,0)*NVL(SFB_DIVFLOAT_1(a.SUCCCONnesTAB,a.ATTCONnesTAB,
                                    NVL(a.NBRRNCRELCSRAB_CONV11,0)+NVL(a.NBRRNCRELCSRAB_CONV22,
                                    NVL(a.NBRRABCSRELIUCONN_CONV11,0)+NVL(a.NBRRABCSRELIUCONN_CONV22,
                                    round(SFB_DIVFLOAT_1(NVL(a.NBRRNCRELCSRAB_CONV11,0)+NVL(a.NBRRABCSRELIUCONN_CONV11,NVL(a.SUCCRABASSIGnesTABCS_CONV11,
                                    NVL(a.NBRRNCRELCSRAB_CONV55,
                                    NVL(a.NBRRABCSRELIUCONN_CONV55,
                                    round(SFB_DIVFLOAT_1(NVL(a.NBRRNCRELCSRAB_CONV55,0)+NVL(a.NBRRABCSRELIUCONN_CONV55,NVL(SUCCRABASSIGnesTABCS_CONV55,
                                    NVL(a.NBRRNCRELPSRAB,0)-NVL(a.REL_REQ_PS_16,0)-NVL(a.REL_REQ_PS_40,
                                    NVL(a.NBRRABPSRELIUCONN,
                                    round(SFB_DIVFLOAT_1(NVL(a.NBRRNCRELPSRAB,0)+NVL(a.NBRRABPSRELIUCONN,0)- NVL(a.RAB_PS_REL_IU_CONN_16,0)-NVL(a.RAB_PS_REL_IU_CONN_40,a.SUCCRABASSIGnesTABPS,
                                    NVL(a.NBRBLOCKSRECEIVEDCS_CONV,
                                    NVL(a.NBRERRBLOCKSRECEIVEDCS,
                                    round(NVL(SFB_DIVFLOAT_1(a.NBRERRBLOCKSRECEIVEDCS_CONV55,a.NBRBLOCKSRECEIVEDCS_CONV55,
                                    round(NVL(SFB_DIVFLOAT_1(a.NBRERRBLOCKSRECEIVEDPS,a.NBRBLOCKSRECEIVEDPS,
                                    NVL(b.ATTOUTCS,
                                    NVL(b.FAILOUTCS,
                                    round(SFB_DIVFLOAT_1(NVL(b.ATTOUTCS,0)-NVL(b.FAILOUTCS,NVL(b.ATTOUTCS,
                                    NVL(b.ATTOUTPSUTRAN,
                                    NVL(b.FAILOUTPSUTRAN,
                                    round(SFB_DIVFLOAT_1(NVL(b.ATTOUTPSUTRAN,0)-NVL(b.FAILOUTPSUTRAN,NVL(b.ATTOUTPSUTRAN,2)
                                    
                                    from tpc_utrancell_ne a ,TPC_UTRANCELL_HO_NE b,TPC_UTRANCELL_HSPA_NE c
                                    
                            where  a.first_result =  current year to hour - $para units hour ||':00:00'
                            and a.first_result = b.first_result
                            and a.first_result = c.first_result
                            and a.ne_id = b.ne_id
                            and a.ne_id = c.ne_id " ;
                                            
         print " $sel_sql\n " ;
       my   $rsite   =   $npmdb_dbh -> prepare( $sel_sql );
         $rsite -> execute();
       my   $ref_data   =   $rsite -> fetchall_arrayref();
       $rsite -> finish;
      
       $gisdb_dbh -> do ( " delete from BTS_PM_TD where first_result <= sysdate - 74/24 " );
      
       $gisdb_dbh -> do ( " delete from BTS_PM_TD where first_result = to_date(to_char((sysdate - $para/24),'YYYY-MM-DD HH24'),'SYYYY-MM-DD HH24:MI:SS') " );

       my   $MM   =   0 ;
       foreach   my   $row  (@ $ref_data )
      {
           my   @data   =  @ $row ;
           my   $dataLen   =   @data ;
      
           my   $gisInc   =   " insert into BTS_PM_TD  
                                      values (to_date('$data[0]','SYYYY-MM-DD HH24:MI:SS'),$data[1], " ;
           for ( my   $HH   =   2 ;  $HH   <   $dataLen ;  $HH ++ ){
               $gisInc   =   $gisInc   .   " '$data[$HH]', " ;
          }                        
           $gisInc   =   substr ( $gisInc , 0 , length ( $gisInc )  -   1 );
                                      
             $gisInc   =   $gisInc   .   "  ) " ;
         # print"$gisInc   \n";
          #first_result, ne_id, cstraffic_conv11, cstraffic_conv22, cstraffic_conv55, tsnbrassnbruul, tsnbrassnbrudl, bruul, brudl, tddmaxtcp, tddmeantcp, nbrerrblocksreceivedcs_conv55, nbrblocksreceivedcs_conv55, nbrerrblocksreceivedps, nbrblocksreceivedps, succmacdestab, succrbestab, attmacdestab, attrbestab
           $rsite   =   $gisdb_dbh -> do ( $gisInc );
           $MM ++ ;
           print   " $MM\n " ;
      }    
    
     $gisdb_dbh -> do ( " commit " );

}
     $npmdb_dbh -> disconnect();
     $gisdb_dbh -> disconnect();
 exit ( 0 );

复制代码

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

Perl碎碎念
1. 如何去重 #!/usr/bin/perl use strict; my %hash; while(&lt;&gt;){ chomp; print &quot;$_n&quot; unless
如何用perl将表格中不同列的数据进行拼凑，然后将拼凑后的数据用“|”连接在一起
最近写了一个perl脚本，实现的功能是将表格中其中两列的数据进行拼凑，然后将拼凑后的数据用“|”连接在一起。表格内容如下： 员工号码员工姓名职位入职日期1001张三销售1980/12/17 0:00:
基于表的数据字典构造MySQL建表语句
表的数据字典格式如下：如果手动写MySQL建表语句，确认麻烦，还不能保证书写一定正确。写了个Perl脚本，可快速构造MySQL脚本语句。脚本如下：#!/usr/bin/perluse strict;m
如何用Perl对Excel的数据进行提取并分析
巡检类工作经常会出具日报，最近在原有日报的基础上又新增了一个表的数据量统计日报，主要是针对数据库中使用较频繁，数据量又较大的31张表。该日报有两个sheet组成，第一个sheet是数据填写，第二个sh
如何用Perl截取报文
在实际生产环境中，常常需要从后台日志中截取报文，报文的形式类似于.........一个后台日志有多个报文，每个报文可由操作流水唯一确定。以前用AWK写过一个，程序如下：beginline=`awk &
如何通过关键词匹配统计其出现的频率
最近写的一个perl程序，通过关键词匹配统计其出现的频率，让人领略到perl正则表达式的强大，程序如下：#!/usr/bin/perluse strict;my (%hash,%hash1,@arra
漫谈 Perl 的 web 应用开发框架
忍不住在 PerlChina 邮件列表中盘点了一下 Perl 里的 Web 应用框架（巧的是 PerlBuzz 最近也有一篇相关的讨论帖），于是乎，决定在我自己的 blog 上也贴一下 :) 原生 CGI/FastCGI 的 web app 对于较小的应用非常合适，但稍复杂一些就有些痛苦，但运行效率是最高的 ;) 如果是自己用 Perl 开发高性能的站，多推荐之。 Catalyst, CGI::A
perl中bless的理解
bless有两个参数：对象的引用、类的名称。 类的名称是一个字符串，代表了类的类型信息，这是理解bless的关键。 所谓bless就是把 类型信息 赋予 实例变量。 程序包括5个文件： person.pm ：实现了person类 dog.pm ：实现了dog类 bless.pl ： 正确的使用bless bless.wrong.pl ： 错误的使用bless bless.cc ： 使用C++语言实
PERL GB2312 UTF-8 编码转换
gb2312转Utf的方法： use Encode; my $str = "中文"; $str_cnsoftware = encode("utf-8", decode("gb2312", $str));   Utf转 gb2312的方法： use Encode; my $str = "utf8中文"; $str_cnsoftware = encode("gb2312", decode("utf-8
perl 计算硬盘利用率
  perl 计算硬盘利用率， 以%来查看硬盘资源是否存在IO消耗cpu资源情况； 部份代码参考了iostat源码；     #!/usr/bin/perl use Time::HiRes qw(gettimeofday); use POSIX; $SLEEPTIME=3; sub getDiskUtl() { $clock_ticks = POSIX::sysconf( &POSIX::_SC_
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native