changes for insert in chunks

Author: punitcis

src/Utils/Importer/Indi/Alia.php

@@ -20,6 +20,6 @@ public static function read($conn, $item, $group = '', $group_id = 0)
                 $aliaData [] = $data;
             }
         }
-        PersonAlia::insert($aliaData);
+        PersonAlia::on($conn)->insert($aliaData);
     }
 }

src/Utils/Importer/Indi/Even.php

@@ -136,7 +136,7 @@ public static function read($conn, $events, $person, $obje_ids = [])
                 ['adop_famc' , $adop_famc],
                 ['birt_famc' , $birt_famc]
             ];
-                $check = PersonEvent::where($key)->first();
+                $check = PersonEvent::on($conn)->where($key)->first();
                 if(empty($check)){
                     $data = [
                         'person_id' => $person_id,
@@ -159,7 +159,7 @@ public static function read($conn, $events, $person, $obje_ids = [])
                 }
             }
         }
-        PersonEvent::insert($eventData);
+        PersonEvent::on($conn)->insert($eventData);
         $new = new Even;
         $new->otherField($conn,$events,$person);
     }
@@ -285,7 +285,7 @@ public static function otherField($conn, $events, $person){
                 ['birt_famc' , $birt_famc],
             ];
 
-            $record = PersonEvent::where($key)->first();
+            $record = PersonEvent::on($conn)->where($key)->first();
 
             $_group = 'indi_even';
             $_gid = $record->id;

src/Utils/Importer/Indi/Subm.php

@@ -26,6 +26,6 @@ public static function read($conn, $item, $group = '', $group_id = 0, $subm_ids)
             }
         }
 
-        PersonSubm::insert($record);
+        PersonSubm::on($conn)->insert($record);
     }
 }

src/Utils/ParentData.php

@@ -38,7 +38,7 @@ class ParentData
 
     public static function getPerson($conn, $individuals, $obje_ids)
     {
-        $data = [];
+        $ParentData = [];
         foreach($individuals as $k=>$individual){
             $g_id = $individual->getId();
             $name = '';
@@ -111,15 +111,14 @@ public static function getPerson($conn, $individuals, $obje_ids)
             if(empty($check)){
                 $value = ['name'=>$name,'givn'=>$givn,'surn'=>$surn,'sex'=>$sex,'uid'=>$uid,'rin'=>$rin,'resn'=>$resn,'rfn'=>$rfn,'afn'=>$afn];
 
-                $data[] = $value;
+                $ParentData[] = $value;
             }
             // $person = Person::on($conn)->updateOrCreate($key,$value);
             // otherFields::insertOtherFields($conn,$individual,$obje_ids,$person);
         }
-
-        foreach (array_chunk($data, 200) as $chunk)
+        foreach (array_chunk($ParentData, 200) as $chunk)
         {
-          Person::insert($chunk->toArray());
+          Person::on($conn)->insert($chunk->toArray());
         }
         otherFields::insertOtherFields($conn,$individuals,$obje_ids);
     }