Return to dbops.pm CVS log

Up to [local] / wpscripts / epickup

Annotation of wpscripts/epickup/dbops.pm, Revision 1.1

1.1     ! yason       1: #!/usr/bin/perl
        !             2: use DBI;
        !             3: use strict;
        !             4: use conv; # to_local()
        !             5: package dbops;
        !             6:
        !             7: our $EPD_ZAYAVKA_T = 0;
        !             8: our $EPD_PROBA_T = 1;
        !             9:
        !            10: our $server = "MSSQL";
        !            11: our $user = "it_men";
        !            12: our $pass = "itmen712";
        !            13: our $dsn = "DBI:Sybase:server=$server";
        !            14: our $table = 'T$_EPD_File';
        !            15: our $dbh;
        !            16: our $sth;
        !            17:
        !            18: sub connect()
        !            19: {
        !            20:     $dbh = DBI->connect($dsn, $user, $pass) or die "unable to connect to server $DBI::errstr";
        !            21: }
        !            22:
        !            23:
        !            24: sub select()
        !            25: {
        !            26:     $dbh->do("use Manager");
        !            27: }
        !            28:
        !            29:
        !            30: sub disconnect()
        !            31: {
        !            32:     $dbh->disconnect();
        !            33: }
        !            34:
        !            35:
        !            36: sub fetch($)
        !            37: {
        !            38:     my $file_type = shift;
        !            39:     my $i = 0;
        !            40:     my @ID;
        !            41:     my @win_paths;
        !            42:
        !            43:
        !            44:     $sth = $dbh->prepare ("SELECT ID,win_path FROM $table WHERE File_type=$file_type AND Ready=1 AND Backed_up=0")
        !            45:        or die("fetch");
        !            46:
        !            47:     $sth->execute( ) or die "unable to execute query! error $DBI::errstr";
        !            48:
        !            49:     while( ($ID[$i], $win_paths[$i]) = $sth->fetchrow_array() )
        !            50:     {
        !            51:        if ($win_paths[$i] ne '')
        !            52:        {
        !            53:            # reuse with real unix path
        !            54:            $win_paths[$i] = conv::to_local($win_paths[$i]);
        !            55:
        !            56:            # NOT checking existence of file here
        !            57:        }
        !            58:        else
        !            59:        {
        !            60:            log::stdout("fetch(): void element $win_paths[$i]\n");
        !            61:        }
        !            62:
        !            63:        $i++;
        !            64:     }
        !            65:
        !            66:     $sth->finish();
        !            67:
        !            68:     return( (\@ID, \@win_paths) );
        !            69:
        !            70: } # fetch()
        !            71:
        !            72:
        !            73: sub set($$$)
        !            74: {
        !            75:     my $ID = shift;
        !            76:     my $field = shift;
        !            77:     my $value = shift;
        !            78:
        !            79:     $sth = $dbh->prepare ("UPDATE $table SET $field=$value WHERE ID=$ID");
        !            80:     $sth->execute() or die "unable to update table! error $DBI::errstr";
        !            81:
        !            82:     # Notreached if error
        !            83:
        !            84:     $sth->finish();
        !            85:
        !            86: }
        !            87:
        !            88:
        !            89: sub fixate($)
        !            90: {
        !            91:     my $ID = shift;
        !            92:
        !            93:
        !            94:     $sth = $dbh->prepare ("UPDATE $table SET Backed_up=1 WHERE ID=$ID");
        !            95:     $sth->execute() or die "unable to update table! error $DBI::errstr";
        !            96:
        !            97:     $sth->finish();
        !            98: }
        !            99:
        !           100:
        !           101: sub markok($)
        !           102: {
        !           103:     my $ID = shift;
        !           104:
        !           105:
        !           106:     $sth = $dbh->prepare ("UPDATE $table SET Backed_up=1 WHERE ID=$ID");
        !           107:     $sth->execute() or die "unable to update table! error $DBI::errstr";
        !           108:
        !           109:     $sth->finish();
        !           110: }
        !           111:
        !           112: return(1);