new upstream release (3.3.0); modify package compatibility for Stretch

[ossec-hids.git] / debian / ossec-hids / usr / share / doc / ossec-hids / contrib / ossecmysql.pm

diff --git a/debian/ossec-hids/usr/share/doc/ossec-hids/contrib/ossecmysql.pm b/debian/ossec-hids/usr/share/doc/ossec-hids/contrib/ossecmysql.pm
new file mode 100644 (file)
index 0000000..260c3e2
--- /dev/null
+++ b/debian/ossec-hids/usr/share/doc/ossec-hids/contrib/ossecmysql.pm
@@ -0,0 +1,75 @@
+use DBI;
+use strict;
+package ossecmysql;
+
+sub new(){
+       my $type = shift;
+       my %conf=@_;
+       my $self={};
+       my $flag;
+       $self->{database}=$conf{database};
+       $self->{dbhost}=$conf{dbhost};
+       $self->{dbport}=$conf{dbport};
+       $self->{dbuser}=$conf{dbuser};
+       $self->{dbpasswd}=$conf{dbpasswd};
+
+       $self->{dsn} = "DBI:mysql:database=$self->{database};host=$self->{dbhost};port=$self->{dbport}";
+        $self->{dbh} = DBI->connect($self->{dsn}, $self->{dbuser},$self->{dbpasswd});
+       bless $self, $type;
+}
+sub fetchrecord(){
+       my $self= shift ;
+       my ($rows)=@_;
+       my ($pointer,$numrows,$fields)=(${$rows}[0],${$rows}[1],${$rows}[2]);
+       my @result;
+       return if $pointer == $numrows;
+       for (my $i=0; $i <  $fields; $i ++){
+        my $field=  @{$rows}[($pointer * $fields) + 3 + $i ];
+        push (@result, $field);
+       }
+       ${$rows}[0] ++;
+       
+       return @result;
+}
+sub fetchrows(){
+       my $self = shift ;
+       my ($query)=shift;
+       my @params= @_;
+        my @rows;
+        my $numFields;
+        my $numRows;
+        $numRows=$numFields=0;
+        $self->{sth}=$self->{dbh}->prepare($query);
+        $self->{sth}->execute(@params) ;
+        $numRows = $self->{sth}->rows;
+        my @row=();
+       return @rows unless $numRows>0;
+        $numFields = $self->{sth}->{'NUM_OF_FIELDS'};
+       push (@rows,0,$numRows,$numFields);
+       while(@row=$self->{sth}->fetchrow_array){
+                push (@rows,@row);
+        }
+
+        $self->{sth}->finish;
+        return @rows;
+       
+}
+
+sub execute(){
+       my $self = shift ;
+       my $flag;
+       my ($query)=shift;
+       my @params= @_;
+        my @rows= ();
+        my $numFields;
+        my $numRows;
+        $numRows=$numFields=0;
+        $self->{sth} = $self->{dbh}->prepare($query);
+        return $self->{sth}->execute(@params) ;
+}
+
+sub lastid(){
+       my $self = shift ;
+       return $self->{sth}->{mysql_insertid};
+}
+1