Add unittest for ConfigDBConnector

Author: seiferteric

setup.py

@@ -4,6 +4,7 @@
     'redis>=4.5.4;python_version >= "3.0"',
     'redis>=3.5.3;python_version < "3.0"',
     'redis-dump-load',
+    'fakeredis',
 ]
 
 high_performance_deps = [

test/test_configdb.py

@@ -0,0 +1,31 @@
+import os
+import sys
+
+from unittest import mock
+
+from unittest import TestCase
+
+modules_path = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+sys.path.insert(0, os.path.join(modules_path, 'src'))
+
+import swsssdk
+import fakeredis
+
+
+class TestConfigDB(TestCase):
+    def test__configdb_pipe(self):
+
+        s_db = swsssdk.ConfigDBPipeConnector()
+        #Use fakeredis to mock redis db
+        r_db = fakeredis.FakeStrictRedis(version=5)
+        s_db.get_redis_client = lambda db_name: r_db
+        s_db.db_name = "CONFIG_DB"
+
+        s_db.mod_config({'TABLE_NAME': { 'row_key': {'column_key1': 'valueA1', 'column_key2': 'valueB1'}}})
+        self.assertEqual(r_db.hget('TABLE_NAME|row_key', 'column_key1'), b'valueA1')
+        self.assertEqual(r_db.hget('TABLE_NAME|row_key', 'column_key2'), b'valueB1')
+        s_db.mod_config({'TABLE_NAME': { 'row_key': {'column_key1': 'valueA2'}}}, table_delete='TABLE_NAME')
+        self.assertEqual(r_db.hget('TABLE_NAME|row_key', 'column_key1'), b'valueA2')
+        self.assertEqual(r_db.hget('TABLE_NAME|row_key', 'column_key2'), None)
+        
+