perl - 操作数据库

插入DB

use strict;
use DBI;
use DBD::Oracle;

my $dbh=DBI->connect('DBI:Oracle:host=localhost;SID=XE','tristan','654321',{PrintError=>1,RaiseError=>1,ora_session_mode=>2});

my $sql = qq{ CREATE TABLE tristan.employees ( id INTEGER NOT NULL, 
                                       name VARCHAR2(128), 
                                       title VARCHAR2(128), 
                                       phone CHAR(8) 
                                     ) };
$dbh->do( $sql );

$dbh->disconnect();

访问数据库的代码

use strict;
use DBI;
use DBD::Oracle;

my $dbh=DBI->connect('DBI:Oracle:host=localhost;SID=XE','tristan','654321',{PrintError=>1,RaiseError=>1,ora_session_mode=>2});

my $sql = "select accout_no, cust_name from tristan.tbl_cust_info";
my $sth = $dbh->prepare($sql);
$sth->execute();

#my( $a, $b);
#$sth->bind_columns( \$a, \$b);
#while($sth->fetchrow()) {
#  print "$a, $b\n";
#}

my @row;
while(@row=$sth->fetchrow_array()) {
  print "$row[0], $row[1]\n";
}

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

插入DB

#!c:/perl/bin/perl -X
use DBI;
use DBD::Oracle;

my $dbh=DBI->connect('DBI:Oracle:host=localhost;SID=XE','tristan','654321',{RaiseError=>1, AutoCommit => 0});

my @records = (
                [ 0, "Larry Wall",      "Perl Author",  "555-0101" ],
                [ 12, "Tim Bunce",       "DBI Author",   "555-0202" ],
                [ 2, "Randal Schwartz", "Guy at Large", "555-0303" ],
                [ 3, "Doug MacEachern", "Apache Man",   "555-0404" ] 
              );

my $sql = qq{ INSERT INTO tristan.employees VALUES ( ?, ?, ?, ? ) };
my $sth = $dbh->prepare( $sql );

for( @records ) {
  eval {
    $sth->bind_param( 1, @$_->[0],  { TYPE => SQL_INTEGER } );
    $sth->bind_param( 2, @$_->[1],  { TYPE => SQL_VARCHAR } );
    $sth->bind_param( 3, @$_->[2], { TYPE => SQL_VARCHAR } );
    $sth->bind_param( 4, @$_->[3], { TYPE => SQL_VARCHAR } );
    $sth->execute();
    $dbh->commit();
  };

  if( $@ ) {
    warn "Database error: $DBI::errstr\n";
    $dbh->rollback(); #just die if rollback is failing
  }
}

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