diff --git a/app/Controllers/AirFlow.php b/app/Controllers/AirFlow.php index 0b43c7c..8461c03 100644 --- a/app/Controllers/AirFlow.php +++ b/app/Controllers/AirFlow.php @@ -21,18 +21,27 @@ class AirFlow extends BaseController WHERE pc = 0 limit 2"; $query = $this->db->query($mysql); - $row = $query->getRowArray(); + // $row = $query->getRowArray(); + while ($row = $query->getUnbufferedRow()) { - foreach ($row as $rw){ - log_message('critical', "AirFlow::processLoadData ********* =========================in " ); - log_message('critical', "AirFlow::flowNewAccount ********* ALL ".serialize($rw) ); - // log_message('critical', "AirFlow::processLoadData ********* ALL ". $rw["customer_uid"] ); - log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $rw[0]["customer_uid"] ); - log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $rw->customer_uid ); - log_message('critical', "AirFlow::processLoadData ********* =========================out" ); + log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $row->customer_uid ); + +// echo $row->customer_uid; +// echo $row->name; +// echo $row->body; } +// foreach ($row as $rw){ +// log_message('critical', "AirFlow::processLoadData ********* =========================in " ); +// log_message('critical', "AirFlow::flowNewAccount ********* ALL ".serialize($rw) ); +// // log_message('critical', "AirFlow::processLoadData ********* ALL ". $rw["customer_uid"] ); +// log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $rw[0]["customer_uid"] ); +// log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $rw->customer_uid ); +// log_message('critical', "AirFlow::processLoadData ********* =========================out" ); +// +// } + return 0; }