From 6b1bc3691f5b20f7bd78f32d63ee671ab960df6c Mon Sep 17 00:00:00 2001
From: Rene Krenn <rkrenn@sipwise.com>
Date: Fri, 31 May 2024 17:19:30 +0200
Subject: [PATCH] MT#60120 dao methods to purge lnp numbers

Change-Id: I80a642557c7f118a9e1b9aba763147915ec9ccf4
(cherry picked from commit f234067ef8503b32e0439e467d37559a5236d9ac)
---
 .../Dao/Trunk/billing/lnp_numbers.pm          | 11 +++++++++
 .../Dao/Trunk/billing/lnp_providers.pm        | 24 +++++++++++++++++++
 2 files changed, 35 insertions(+)

diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm
index 4cb298a..82b5868 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_numbers.pm
@@ -33,6 +33,8 @@ our @EXPORT_OK = qw(
     delete_row
     
     delete_numbers
+
+    truncate
     
     getinsertstatement
 
@@ -142,6 +144,15 @@ sub delete_row {
 
 }
 
+sub truncate {
+
+    check_table();
+    my $db = &$get_db();
+    $db->truncate_table($tablename);
+    $db->vacuum($tablename);
+
+}
+
 sub delete_numbers {
 
     my ($xa_db,$numbers) = @_;
diff --git a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm
index f438b82..826b144 100644
--- a/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm
+++ b/lib/NGCP/BulkProcessor/Dao/Trunk/billing/lnp_providers.pm
@@ -31,6 +31,8 @@ our @EXPORT_OK = qw(
     insert_row
     update_row
     delete_row
+
+    delete_all
     
     findby_prefix
     findby_nameprefixauthoritativeskiprewrite
@@ -158,6 +160,28 @@ sub delete_row {
 
 }
 
+sub delete_all {
+
+    my ($xa_db) = @_;
+
+    check_table();
+    my $db = &$get_db();
+    $xa_db //= $db;
+    my $table = $db->tableidentifier($tablename);
+
+    my $stmt = 'DELETE FROM ' . $table;
+
+    my $count;
+    if ($count = $xa_db->db_do($stmt,@params)) {
+        rowsdeleted($db,$tablename,$count,$count,getlogger(__PACKAGE__));
+        return 1;
+    } else {
+        rowsdeleted($db,$tablename,0,0,getlogger(__PACKAGE__));
+        return 0;
+    }
+
+}
+
 sub insert_row {
 
     my $db = &$get_db();