Perl类操作mysql

#!/user/bin/perl -w
package Perl4Mysql;
use strict;
use DBI;
use Data::Dumper;


sub new { #host, dbname, user, password, port
    my $class = shift;
    
    my ($host, $dbName, $user, $password, $port) = @_;
    $host = "localhost" if !defined($host) or $host eq "";
    $dbName = "mysql" if !defined($dbName) or $dbName eq "";
    $user = "root" if !defined($user) or $user eq "";
    $password = "" if !defined($password) or $password eq "";
    $port = 3306 if !defined($port);
    
    my $self = {
        "host"=>$host,
        "database"=>$dbName,
        "user"=>$user,
        "password"=>$password,
        "port"=>$port
    };
    
    bless $self, $class;
    
    return $self;
}

sub query { #sql string for select
    my ($self, $sql) = @_;
    my @result;
    my ($database,$host, $user,$password,$port) = (
        $self->{database},
        $self->{host}, 
        $self->{user}, 
        $self->{password}, 
        $self->{port}
    );
    my $dbh = DBI->connect("DBI:mysql:database=$database;host=$host;port=$port", $user, $password)
        or die "Can‘t connect to database: $DBI::errstr\n";    #连接数据库
    my $sth = $dbh->prepare($sql);                        #准备
    $sth->execute();                                #执行
    
    while(my @res = $sth->fetchrow_array())    {
        
        push @result, \@res;
    }                                                #打印抽取结果
    $sth->finish;                                    #结束句柄
    $dbh->disconnect;                                #断开
    return \@result;
}
#执行一条语句
sub do {
    my ($self, $sql) = @_;
    my ($database,$host, $user,$password,$port) = (
        $self->{database},
        $self->{host}, 
        $self->{user}, 
        $self->{password}, 
        $self->{port}
    );
    my $dbh = DBI->connect("DBI:mysql:database=$database;host=$host;port=$port", 
                            $user, 
                            $password)
        or die "Can‘t connect to database: $DBI::errstr\n";    #连接数据库

    my $rows = $dbh->do($sql) or die "Can‘t execute $sql: $dbh->errstr\n";
#    $dbh->commit or die "commit error :$dbh->errstr\n";
    $dbh->disconnect;                                #断开
    
    return $rows;
}
#执行多条带占位符（?）的sql
sub execMultiSql {
    my ($self, $sql, $params) = @_;
    my ($database,$host, $user,$password,$port) = (
        $self->{database},
        $self->{host}, 
        $self->{user}, 
        $self->{password}, 
        $self->{port}
    );
    my $dbh = DBI->connect("DBI:mysql:database=$database;host=$host;port=$port", 
                            $user, 
                            $password)
        or die "Can‘t connect to database: $DBI::errstr\n";    #连接数据库

    my $sth = $dbh->prepare($sql);
    my $rows = 0;
    eval {
        foreach my $ref_param (@{$params})
        {
            $rows += $sth->execute(@{$ref_param});
        }
    
        $sth->finish;
        $dbh->disconnect;                                #断开
    };
    if($@) {
        print "an error: $@,continue... \n";
        $dbh->rollback;
        $sth->finish;
        $dbh->disconnect;
        return 0;
    }
    return $rows;
}

sub setHost {
    my ($self, $host) = @_;
    $self->{host} = $host;
}
sub getHost {
    my $self = shift;
    return $self->{host};
}
sub setDB {
    my ($self, $db) = @_;
    $self->{database} = $db;
}
sub getDB {
    my $self = shift;
    return $self->{database};
}
sub getUser {
    my $self = shift;
    return $self->{user};
}
sub setUser {
    my ($self, $user) = @_;
    $self->{user} = $user;
}
sub setPassword {
    my ($self, $password) = @_;
    $self->{password} = $password;
}
sub getPort {
    my $self = shift;
    return $self->{port};
}
sub setPort {
    my ($self, $port) = @_;
    $self->{port} = $port;
}


1;

my @param;

my $sqltemp = "insert blog_comment(content, date, userName) values(?, sysdate(), ?);";
my @p1 = ("this is ime.", "ok");
my @p2 = ("okokla, yoin.","jack");
push @param, \@p1;  #将两个参数以引用放入进去
push @param, \@p2;

my $rows = $mysql->execMultiSql($sqltemp, \@param);
print $rows;


my $ref_result = $mysql->query("select count(*) from blog_comment");
print Dumper($ref_result);