From 7cbbff0be0d82809f10ccb45045d9a56ec5a35c3 Mon Sep 17 00:00:00 2001
From: Rene Krenn <rkrenn@sipwise.com>
Date: Wed, 12 May 2021 13:26:13 +0200
Subject: [PATCH] TT#121785 provisioning::voip_subscribers::findby_id finder
 method

Change-Id: Ic6e377c7b89cdedcc6e94b541f4db37b023b5a56
(cherry picked from commit ef52bd86b9d3b4204da25823b45ecf6c6c5c0bef)
---
 .../Trunk/provisioning/voip_subscribers.pm    | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm
index 2516ba5..dc99770 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/provisioning/voip_subscribers.pm
@@ -29,6 +29,7 @@ our @EXPORT_OK = qw(
     update_row
 
     findby_uuid
+    findby_id
 );
 
 my $tablename = 'voip_subscribers';
@@ -89,6 +90,24 @@ sub findby_uuid {
 
 }
 
+sub findby_id {
+
+    my ($xa_db,$id,$load_recursive) = @_;
+
+    check_table();
+    my $db = &$get_db();
+    $xa_db //= $db;
+    my $table = $db->tableidentifier($tablename);
+
+    my $stmt = 'SELECT * FROM ' . $table . ' WHERE ' .
+            $db->columnidentifier('id') . ' = ?';
+    my @params = ($id);
+    my $rows = $xa_db->db_get_all_arrayref($stmt,@params);
+
+    return buildrecords_fromrows($rows,$load_recursive)->[0];
+
+}
+
 sub update_row {
 
     my ($xa_db,$data) = @_;