view release on metacpan or  search on metacpan

lib/Tie/Array/QueueExpire.pm  view on Meta::CPAN

    my $class = $_[0];
    my %data;
    $data{ _file }            = $_[1];
    $data{ _serialize }       = $_[2] || 0;
    $data{ _mode }            = $_[3] || 0600;
    $data{ _delete_on_start } = $_[4] || 0;

    my $serialiser;
    if ( $data{ _serialize } )
    {
        use Data::Serializer;
        $serialiser = Data::Serializer->new( compress => 0 );
        $data{ _serialize } = $serialiser;
    }
    my $dbfile = $data{ _file };
    unlink $dbfile if ( -f $dbfile && $data{ _delete_on_start } );
    my $dbh            = DBI->connect( "dbi:SQLite:dbname=$dbfile", "", "" );
    my $sql_list_table = "SELECT name FROM sqlite_master WHERE type='table' ORDER BY name;";
    my $ary_ref        = $dbh->selectall_hashref( $sql_list_table, 'name' );
    unless ( exists( $ary_ref->{ 'queue' } ) )
    {
        my $sql = "CREATE TABLE queue( key text , val text );";