#!/usr/bin/perl
use strict;
use warnings;
use DBI;
use threads;

my $dsn = 'DBI:Sybase:server=sql1';
my $dbh = DBI->connect($dsn, "test", 'oray.com');
die "unable to connect to server $DBI::errstr" unless $dbh;
$dbh->do("use portscan");
my $query = "SELECT domainname FROM psinfo";
my $sth = $dbh->prepare ($query) or die "prepare failed\n";
$sth->execute() or die "unable to execute query $query   error $DBI::errstr";

my $line;
my $myport;
while ($line = $sth->fetchrow_array()) {
my $new_thread = threads->new(\&scan_domain, $line);
print "$myport\n";  #for test
my $upd_sth = $dbh->prepare("update psinfo set port=\'$myport\' where domainname=\'$line\'");
$upd_sth->execute() or die "unable to execute update line where name is $line! error $DBI::errstr";
$upd_sth->finish;
}
sub scan_domain {
		my $s_myport;
        my $domain_name = shift;
        print "started thread for $domain_name\n";
        my @list =`nmap $line`;
        foreach(@list){      
			if($_=~/open/g){
				$_ =~ s/\/.*//g;
				if($s_myport)
				{$s_myport=$s_myport.','.$_;chomp $s_myport;} 
				else{$s_myport=$_; chomp $s_myport} 
			}
		}
		$myport=$s_myport;
}

$sth->finish;