Merge pull request #13 from genealogiawebsite/optimse

Bulk inserts.

Author: curtisdelicata

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

@@ -117,27 +117,28 @@ public static function read($conn, $events, $person, $obje_ids = [])
                 break;
                 default:
             }
-                $adop = '';
-                $adop_famc = '';
-                $birt_famc = '';
-                // store Even
-                $key = [
-                    ['person_id', $person_id],
-                    ['title', $class_name],
-                    ['type', $type],
-                    ['attr', $attr],
-                    ['date', $date],
-                    ['plac', $plac],
-                    ['phon', $phon],
-                    ['caus', $caus],
-                    ['age', $age],
-                    ['agnc', $agnc],
-                    ['adop', $adop],
-                    ['adop_famc', $adop_famc],
-                    ['birt_famc', $birt_famc],
-                ];
-                $check = PersonEvent::where($key)->first();
-                if (empty($check)) {
+            $adop = '';
+            $adop_famc = '';
+            $birt_famc = '';
+            // store Even
+            $key = [
+                ['person_id' , $person_id],
+                ['title'     , $class_name],
+                ['type'      , $type],
+                ['attr'      , $attr],
+                ['date'      , $date],
+                ['plac'      , $plac],
+                ['phon'      , $phon],
+                ['caus'      , $caus],
+                ['age'       , $age],
+                ['agnc'      , $agnc],
+                ['adop'      , $adop],
+                ['adop_famc' , $adop_famc],
+                ['birt_famc' , $birt_famc]
+            ];
+                $check = PersonEvent::on($conn)->where($key)->first();
+                if(empty($check)){
+                  
                     $data = [
                         'person_id' => $person_id,
                         'title'     => $class_name,
@@ -159,9 +160,9 @@ public static function read($conn, $events, $person, $obje_ids = [])
                 }
             }
         }
-        PersonEvent::insert($eventData);
-        $new = new Even();
-        $new->otherField($conn, $events, $person);
+        PersonEvent::on($conn)->insert($eventData);
+        $new = new Even;
+        $new->otherField($conn,$events,$person);
     }
 
     public static function otherField($conn, $events, $person)
@@ -287,7 +288,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

@@ -100,8 +100,10 @@ public static function getPerson($conn, $individuals, $obje_ids)
             // $person = Person::on($conn)->updateOrCreate($key,$value);
             // otherFields::insertOtherFields($conn,$individual,$obje_ids,$person);
         }
-
-        Person::insert($ParentData);
-        otherFields::insertOtherFields($conn, $individuals, $obje_ids);
+        foreach (array_chunk($ParentData, 200) as $chunk)
+        {
+          Person::on($conn)->insert($chunk->toArray());
+        }
+        otherFields::insertOtherFields($conn,$individuals,$obje_ids);
     }
 }