Replace swsssdk.SonicV2Connector with swsscommon.SonicV2Connector (SWIG wrapper of C++ implementation) in production code

acl_loader/main.py

@@ -10,7 +10,8 @@
 import pyangbind.lib.pybindJSON as pybindJSON
 from natsort import natsorted
 from sonic_py_common import device_info
-from swsssdk import ConfigDBConnector, SonicV2Connector, SonicDBConfig
+from swsssdk import ConfigDBConnector, SonicDBConfig
+from swsscommon.swsscommon import SonicV2Connector
 
 
 def info(msg):

config/config_mgmt.py

@@ -14,7 +14,8 @@
 
     # SONiC specific imports
     import sonic_yang
-    from swsssdk import ConfigDBConnector, SonicV2Connector, port_util
+    from swsssdk import ConfigDBConnector, port_util
+    from swsscommon.swsscommon import SonicV2Connector
 
     # Using load_source to 'import /usr/local/bin/sonic-cfggen as sonic_cfggen'
     # since /usr/local/bin/sonic-cfggen does not have .py extension.

config/main.py

@@ -16,7 +16,8 @@
 from portconfig import get_child_ports
 from sonic_py_common import device_info, multi_asic
 from sonic_py_common.interface import get_interface_table_name, get_port_table_name
-from swsssdk import ConfigDBConnector, SonicV2Connector, SonicDBConfig
+from swsssdk import ConfigDBConnector, SonicDBConfig
+from swsscommon.swsscommon import SonicV2Connector
 from utilities_common.db import Db
 from utilities_common.intf_filter import parse_interface_in_filter
 import utilities_common.cli as clicommon

config/nat.py

@@ -3,7 +3,7 @@
 import click
 import ipaddress
 from swsssdk import ConfigDBConnector
-from swsssdk import SonicV2Connector
+from swsscommon.swsscommon import SonicV2Connector
 
 def is_valid_ipv4_address(address):
     """Check if the given ipv4 address is valid"""

scripts/db_migrator.py

@@ -5,7 +5,8 @@
 import traceback
 
 from sonic_py_common import device_info, logger
-from swsssdk import ConfigDBConnector, SonicDBConfig, SonicV2Connector
+from swsssdk import ConfigDBConnector, SonicDBConfig
+from swsscommon.swsscommon import SonicV2Connector
 
 
 SYSLOG_IDENTIFIER = 'db_migrator'

scripts/fanshow

@@ -7,7 +7,6 @@ from __future__ import print_function
 import os
 import sys
 from tabulate import tabulate
-from swsssdk import SonicV2Connector
 from natsort import natsorted
 
 # mock the redis for unit test purposes #
@@ -21,6 +20,7 @@ try:
 except KeyError:
     pass
 
+from swsscommon.swsscommon import SonicV2Connector
 
 header = ['Drawer', 'LED', 'FAN', 'Speed', 'Direction', 'Presence', 'Status', 'Timestamp']
 

scripts/fdbclear

@@ -15,7 +15,6 @@ import argparse
 import json
 import sys
 
-from swsssdk import SonicV2Connector
 
 class FdbClear(object):
 
@@ -32,6 +31,8 @@ class FdbClear(object):
         self.db.publish('APPL_DB','FLUSHFDBREQUEST', msg)
         return
 
+from swsscommon.swsscommon import SonicV2Connector
+
 def main():
 
     parser = argparse.ArgumentParser(description='Clear FDB entries', formatter_class=argparse.RawTextHelpFormatter)

scripts/fdbshow

@@ -30,7 +30,8 @@ import json
 import sys
 
 from natsort import natsorted
-from swsssdk import SonicV2Connector, port_util
+from swsssdk import port_util
+from swsscommon.swsscommon import SonicV2Connector
 from tabulate import tabulate
 
 class FdbShow(object):

scripts/natclear

@@ -13,7 +13,7 @@ import argparse
 import json
 import sys
 
-from swsssdk import SonicV2Connector
+from swsscommon.swsscommon import SonicV2Connector
 
 class NatClear(object):
 

scripts/natshow

@@ -61,7 +61,7 @@ import json
 import sys
 import re
 
-from swsssdk import SonicV2Connector
+from swsscommon.swsscommon import SonicV2Connector
 from tabulate import tabulate
 
 class NatShow(object):

scripts/nbrshow

@@ -32,7 +32,8 @@ import subprocess
 import re
 
 from natsort import natsorted
-from swsssdk import SonicV2Connector, port_util
+from swsssdk import port_util
+from swsscommon.swsscommon import SonicV2Connector
 from tabulate import tabulate
 
 """

scripts/neighbor_advertiser

@@ -17,7 +17,8 @@ import traceback
 import warnings
 
 from sonic_py_common import logger
-from swsssdk import ConfigDBConnector, SonicV2Connector
+from swsssdk import ConfigDBConnector
+from swsscommon.swsscommon import SonicV2Connector
 from netaddr import IPAddress, IPNetwork
 
 

scripts/psushow

@@ -3,7 +3,6 @@
 import argparse
 import sys
 import os
-from swsssdk import SonicV2Connector
 from tabulate import tabulate
 
 # mock the redis for unit test purposes #
@@ -17,6 +16,8 @@ try:
 except KeyError:
     pass
 
+from swsscommon.swsscommon import SonicV2Connector
+
 def psu_status_show(index):
     db = SonicV2Connector(host="127.0.0.1")
     db.connect(db.STATE_DB)

scripts/tempershow

@@ -5,7 +5,7 @@
 from __future__ import print_function
 
 from tabulate import tabulate
-from swsssdk import SonicV2Connector
+from swsscommon.swsscommon import SonicV2Connector
 from natsort import natsorted
 
 

show/fgnhg.py

@@ -4,7 +4,7 @@
 import click
 import utilities_common.cli as clicommon
 from swsssdk import ConfigDBConnector
-from swsssdk import SonicV2Connector
+from swsscommon.swsscommon import SonicV2Connector
 from tabulate import tabulate
 
 

show/main.py

@@ -21,7 +21,8 @@
 import fgnhg
 
 from sonic_py_common import device_info, multi_asic
-from swsssdk import ConfigDBConnector, SonicV2Connector
+from swsssdk import ConfigDBConnector
+from swsscommon.swsscommon import SonicV2Connector
 from tabulate import tabulate
 from utilities_common.db import Db
 import utilities_common.multi_asic as multi_asic_util

sonic_installer/main.py

@@ -14,7 +14,7 @@
 
 import click
 from sonic_py_common import logger
-from swsssdk import SonicV2Connector
+from swsscommon.swsscommon import SonicV2Connector
 
 from .bootloader import get_bootloader
 from .common import run_command, run_command_or_raise

tests/mock_tables/dbconnector.py

@@ -4,10 +4,11 @@
 
 import mock
 import mockredis
-import swsssdk.interface
+import redis
+import swsssdk
 from sonic_py_common import multi_asic
 from swsssdk import SonicDBConfig, SonicV2Connector
-from swsssdk.interface import redis
+from swsscommon import swsscommon
 
 topo = None
 
@@ -137,3 +138,4 @@ def keys(self, pattern='*'):
 mockredis.MockRedis.config_set = config_set
 redis.StrictRedis = SwssSyncClient
 SonicV2Connector.connect = connect_SonicV2Connector
+swsscommon.SonicV2Connector = SonicV2Connector