package sql; use strict; sub query($) { my ($SQLsentence) = (@_); use DBI; my $dbh = DBI->connect("dbi:mysql:dbname=jpc2006",'jpcupdater','mym3xico'); # ejecuta la sentencia sql my $sth = $dbh->prepare($SQLsentence); $sth->execute(); # Recupera los fieldnames. my $fieldnames = $sth->{"NAME"}; # recorrer los fielnames y crea la estructura del data my $length = 0; my %data; while (my @row = $sth->fetchrow_array) { for(my $i=0;$i<@$fieldnames;$i++) { $data{$fieldnames->[$i]}[$length] = $row[$i]; } $length++; } # Retorna la respuesta my %rpta; $rpta{data} = \%data; $rpta{length} = $length; # Cierra la base de Datos $dbh->disconnect; return %rpta; } 1;