X-Git-Url: http://ftp.carnet.hr/carnet-debian/scm?p=ossec-hids.git;a=blobdiff_plain;f=debian%2Fossec-hids%2Fusr%2Fshare%2Fdoc%2Fossec-hids%2Fcontrib%2Fossecmysql.pm;fp=debian%2Fossec-hids%2Fusr%2Fshare%2Fdoc%2Fossec-hids%2Fcontrib%2Fossecmysql.pm;h=260c3e2b19409a6a39e4b8a42817b22612724362;hp=0000000000000000000000000000000000000000;hb=3f728675941dc69d4e544d3a880a56240a6e394a;hpb=927951d1c1ad45ba9e7325f07d996154a91c911b

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
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