use DBI; my $dbh = DBI->connect( "$dbServer", "$dbUser", "$dbPass" ) or print "Could not make connection to database"; open(DAILY, "$updateDir/$fileName") || print "CAN'T OPEN DAILY"; while(){ chomp; my ($field1,$field2,$field3,$field3,$field4,$field5,$field6,$field7,$field8) = split(/,/); if ($field1 == 33){ my $spQuery = "exec my_sp ?,?,?,?,?,?,?"; $insert33 = $dbh->prepare( $spQuery ) or die ( "Cannot prepare statement: ", $dbh->errstr(), "\n" ); $insert33->execute($field1,$field2,$field3,$field4,$field5,$field6,$field7) or die( "Cannot execute statement: ", $insert33->errstr(), "\n" ); $insert33->finish(); } } close(DAILY); #### @field1 AS INTEGER, @field2 AS DATETIME, @field3 AS MONEY, @field4 AS MONEY, @field5 AS MONEY, @field6 AS MONEY, @field7 AS INTEGER AS BEGIN DECLARE @check1 INT SET @check1 = 0 SELECT @check1 = col1 FROM tableX WHERE col3 = @field1 IF @check1 > 0 BEGIN INSERT INTO priceHistory (col1,col2,col3,col4,col5,col6,col7) VALUES (@field1,@field2,@field3,@field4,@field5,@field6,@field7) END END