Código:
<?php //Conexion con BBDD session_start (); $connexio=mysql_connect("localhost","root","") or die ("No se ha podido conectar"); mysql_select_db("mediacion", $connexio)or die ("No se ha podido selecciona la base de datos"); //Conexion con BBDD //Forzar mostrar echos mientras efectua el proceso :D ob_end_flush(); ob_implicit_flush (1); //Forzar mostrar echos mientras efectua el proceso :D //PROCESO DE CARGA DIARIA $connection = ssh2_connect("filomeno", 22); // use any of the ssh2_auth_* methods ssh2_auth_password($connection,"mdevwq", "mdevwq"); echo 'Conectado...'; echo '<br>'; $stream = ssh2_exec($connection, '/md_historic/ExtreuTrucadesMediacio.sh 04 2009 >> /md_historic/merda.out'); echo '<BR>'; echo 'ejecutando scripts...'; //stream_set_blocking($stream, false); echo '<br>'; // The command may not finish properly if the stream is not read to end // $output = stream_get_contents($stream); echo 'Script terminado correctamente, procedemos hacer el ftp.... (ESTO PUEDE TARDAR VARIOS MINUTOS)'; $prueba=ssh2_scp_recv($connection, '/md_historic/consumos.txt', 'consumo.txt'); echo 'FTP terminado, procedemos ha insertar datos en la BBDD!'; echo '<br>'; $sql = "truncate table temporal"; $res = mysql_query($sql,$connexio) or die ("error al truncar tabla"); echo 'Tabla truncada...'; echo '<br>'; $sql1 = "LOAD DATA LOCAL INFILE 'd:/wamp/www/ssh/consumo.txt' INTO TABLE temporal FIELDS TERMINATED BY '|'"; $res2 = mysql_query($sql1,$connexio) or die ("error al cargar tabla temporal"); echo 'Cargado el fixero en la BBDD'; echo '<br>'; $sql2 = "insert into consumo select tipo, fecha, na, count(duracion), sum(duracion) from temporal group by tipo, fecha, na "; $res3 = mysql_query($sql2,$connexio) or die ("error al cargar tabla CONSUMO"); echo 'Insertando datos consumo... '; echo '<br>'; echo 'Procedemos a eliminar el fichero...'; echo '<br>'; $eliminar = ssh2_exec($connection, 'rm -f /md_historic/consumos.txt'); echo'Fichero Eliminado'; echo '<BR>'; echo 'Tarea finalizada :D'; //if ($output == true ) { // echo 'la carga del fixero ha sido cargada correctamente'; // echo '<br>'; //} else { //echo 'La carga del fixero no ha sido cargada'; //} // //if ($prueba == true ) { // echo 'se ha efectuado el ftp correctamente'; //} else { //echo 'no se ha podido efectuar el ftp'; //} ?>