#!/usr/bin/perl -w
#############################################
## mrta2netacct - 1.0 /28.02.2002/
## (c) 2002 BASHbug <bashbug@users.sourceforge.net>
## Import traffic table information from MRTA version <= 0.16
##


#use strict;
use Mysql;

my $host = "localhost";

my $mrta_dbname = "mrta";
my $mrta_user = "mrtauser";
my $mrta_pass = "mrta_password";

my $netacct_dbname = "netacct";
my $netacct_user = "acct";
my $netacct_pass = "acct_password";


#********************* Don't edit any more **************************

my $dbh = Mysql->connect($host, $mrta_dbname, $mrta_user, $mrta_pass);
if($dbh) {print "Connecting to MySQL server success, $mrta_dbname\n";}
else {print "MySQL problems with $mrta_dbname\n"; exit;}

my $dbh_in = Mysql->connect($host, $mrta_dbname, $mrta_user, $mrta_pass);
if($dbh_in) {print "Connecting to MySQL server success, $mrta_dbname\n";}
else {print "MySQL problems with $mrta_dbname\n"; exit;}

my $dbh_out = Mysql->connect($host, $netacct_dbname, $netacct_user, $netacct_pass);
if($dbh_out) {print "Connecting to MySQL server success, $netacct_dbname\n";}
else {print "MySQL problems with $netacct_dbname\n"; exit;}

my $query;
my $query_in;
my $query_out;

$query="SELECT id,saddr FROM clients";
$clients=$dbh->query($query);

@cln=$clients->fetchrow;
if($cln[1] > 23) 
{ print "Wrong MRTA version it is > 0.16"; exit();}

while (@cln=$clients->fetchrow)
{
	my ($id,$ip) = @cln;
	$query_in="SELECT time,input,output FROM traffic WHERE id='$id'";
	$input=$dbh_in->query($query_in);

	while (@in=$input->fetchrow)
	{
 		$query_out="INSERT INTO traffic (ip,time,input,output) VALUES ('$ip', '$in[0]', '$in[1]', '$in[2]')";
	
		print "$query_out\n";
		$dbh_out->query($query_out);
	}
}

$query_out="ALTER TABLE traffic ORDER BY time";
$dbh_out->query($query_out);

