ODL Junit OVSDB

package ovsdb2;

import java.io.IOException;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.Map;
import org.junit.Test;

public class OvsdbSocketTest {

@Test
    public void addString() throws IOException, Throwable {
        OvsdbIO ovsdb = new OvsdbIO();
        ovsdb.start();

        // OVSDB Server Defined UUIDs
        String intuuid = "e7c6fc73-a4a1-4d7d-b6b7-eb2e0d2fa900";
        String bridgetabluuid = "435de935-54e2-474d-aba6-cb85468fcc65";
        String portabluuid = "5aa60514-8a65-4739-8ea9-46fb1906a7ed";
        String ovstbluuid = "2cfdf9dd-e2a3-46b9-b09d-fbc68f23bc5d";

        // OVS User Defined Port Name
        String ovsportname = "vnic0";

        // Array for printing only
        ArrayList printout = new ArrayList();

        // Arrays for JSON obj
        ArrayList intarr0 = new ArrayList();
        ArrayList intarr1 = new ArrayList();
        ArrayList intarr2 = new ArrayList();
        ArrayList intarr3 = new ArrayList();
        ArrayList intarr4 = new ArrayList();
        ArrayList intarr5 = new ArrayList();

        // Arrays for Port
        ArrayList portarr6 = new ArrayList();
        ArrayList portarr7 = new ArrayList();
        ArrayList portarr8 = new ArrayList();
        ArrayList portarr9 = new ArrayList();
        ArrayList portarr10 = new ArrayList();
        ArrayList portarr11 = new ArrayList();

        // Arrays for Bridge
        ArrayList brarr6 = new ArrayList();
        ArrayList brarr7 = new ArrayList();
        ArrayList brarr8 = new ArrayList();
        ArrayList brarr9 = new ArrayList();
        ArrayList brarr10 = new ArrayList();
        ArrayList brarr11 = new ArrayList();

        // Maps for JSON Port
        Map intmap0 = new LinkedHashMap();
        Map intmap1 = new LinkedHashMap();

        // Maps for JSON Bridge
        Map brmap2 = new LinkedHashMap();
        Map brmap3 = new LinkedHashMap();

        // Maps for JSON Port
        Map portmap2 = new LinkedHashMap();
        Map portmap3 = new LinkedHashMap();

        // Maps for Update
        Map updtmap1 = new LinkedHashMap();
        Map updtmap2 = new LinkedHashMap();

        // Arrays for Update
        ArrayList updtarr1 = new ArrayList();
        ArrayList updtarr2 = new ArrayList();
        ArrayList updtarr3 = new ArrayList();
        ArrayList updtarr4 = new ArrayList();
        ArrayList updtarr5 = new ArrayList();
        ArrayList updtarr6 = new ArrayList();
        ArrayList updtarr7 = new ArrayList();

        // Maps for Port Update
        Map insportmap1 = new LinkedHashMap();
        Map insportmap2 = new LinkedHashMap();

        // Arrays for Port Update
        ArrayList insportarr1 = new ArrayList();

        // Maps for Interface Update
        Map insintmap1 = new LinkedHashMap();
        Map insintmap2 = new LinkedHashMap();

        // Arrays for Mutation Op
        ArrayList mutearr1 = new ArrayList();
        ArrayList mutearr2 = new ArrayList();
        ArrayList mutearr3 = new ArrayList();
        ArrayList mutearr4 = new ArrayList();
        ArrayList mutearr5 = new ArrayList();

        // Maps for Mutate Op
        Map mutemap1 = new LinkedHashMap();

        // Arrays for Op Select OVS
        ArrayList opselarr1 = new ArrayList();
        ArrayList opselarr2 = new ArrayList();
        ArrayList opselarr3 = new ArrayList();
        ArrayList opselarr4 = new ArrayList();

        // Maps for Op Select OVS
        Map opselmap1 = new LinkedHashMap();

        // Array for Comment
        ArrayList commarr5 = new ArrayList();

        // Maps for Comment
        Map commmap1 = new LinkedHashMap();

        // Interface
        intmap0.put("rows", intarr0);
        intarr0.add(intmap1);
        intmap1.put("interfaces", intarr1);
        intarr1.add("uuid");
        intarr1.add(intuuid);
        intmap0.put("until", "==");
        intmap0.put("table", "Port");
        intmap0.put("op", "wait");
        intmap0.put("timeout", 0);
        intmap0.put("where", intarr2);
        intarr2.add(intarr3);
        intarr3.add("_uuid");
        intarr3.add("==");
        intarr3.add(intarr4);
        intarr4.add("uuid");
        intarr4.add(portabluuid);
        intmap0.put("columns", intarr5);
        intarr5.add("interfaces");

        // Bridge
        brmap2.put("rows", brarr6);
        brarr6.add(brmap3);
        brarr7.add("uuid");
        brarr7.add(bridgetabluuid);
        brmap3.put("bridges", brarr7);
        brmap2.put("until", "==");
        brmap2.put("table", "Open_vSwitch");
        brmap2.put("op", "wait");
        brmap2.put("timeout", 0);
        brmap2.put("where", brarr8);
        brarr8.add(brarr9);
        brarr9.add("_uuid");
        brarr9.add("==");
        brarr9.add(brarr10);
        brarr10.add("uuid");
        brarr10.add(ovstbluuid);
        brmap2.put("columns", brarr11);
        brarr11.add("bridges");

        // Ports
        portmap2.put("rows", portarr6);
        portarr6.add(portmap3);
        portarr7.add("uuid");
        portarr7.add(portabluuid);
        portmap3.put("ports", portarr7);
        portmap2.put("until", "==");
        portmap2.put("table", "Bridge");
        portmap2.put("op", "wait");
        portmap2.put("timeout", 0);
        portmap2.put("where", portarr8);
        portarr8.add(portarr9);
        portarr9.add("_uuid");
        portarr9.add("==");
        portarr9.add(portarr10);
        portarr10.add("uuid");
        portarr10.add(bridgetabluuid);
        portmap2.put("columns", portarr11);
        portarr11.add("ports");

        // Update
        updtmap1.put("where", updtarr1);
        updtarr1.add(updtarr2);
        updtarr2.add("_uuid");
        updtarr2.add("==");
        updtarr2.add(updtarr3);
        updtarr3.add("uuid");
        updtarr3.add(bridgetabluuid);
        updtmap1.put("op", "update");
        updtmap1.put("table", "Bridge");
        updtmap1.put("row", updtmap2);
        updtmap2.put("ports", updtarr4);
        updtarr4.add("set");
        updtarr4.add(updtarr5);
        updtarr5.add(updtarr6);
        updtarr6.add("uuid");
        updtarr6.add(portabluuid);
        updtarr5.add(updtarr7);
        updtarr7.add("named-uuid");
        updtarr7.add("rowc1ee45e7_e736_4cd2_8e30_55a460d0f11a");

        // Insert Port
        insportmap1.put("uuid-name", "rowc1ee45e7_e736_4cd2_8e30_55a460d0f11a");
        insportmap1.put("op", "insert");
        insportmap1.put("table", "Port");
        insportmap1.put("row", insportmap2);
        insportmap2.put("interfaces", insportarr1);
        insportarr1.add("named-uuid");
        insportarr1.add("row50c0ab47_0077_4ac3_8d84_8b1906a39947");
        insportmap2.put("name", ovsportname);

        // Insert Interface
        insintmap1.put("uuid-name", "row50c0ab47_0077_4ac3_8d84_8b1906a39947");
        insintmap1.put("op", "insert");
        insintmap1.put("table", "Interface");
        insintmap1.put("row", insintmap2);
        insintmap2.put("name", ovsportname);

        // Mutation Op
        mutemap1.put("mutations", mutearr1);
        mutearr1.add(mutearr2);
        mutearr2.add("next_cfg");
        mutearr2.add("+=");
        mutearr2.add(1);
        mutemap1.put("table", "Open_vSwitch");
        mutemap1.put("op", "mutate");
        mutemap1.put("where", mutearr3);
        mutearr3.add(mutearr4);
        mutearr4.add("_uuid");
        mutearr4.add("==");
        mutearr4.add(mutearr5);
        mutearr5.add("uuid");
        mutearr5.add(ovstbluuid);
        opselmap1.put("where", opselarr1);
        opselarr1.add(opselarr2);
        opselarr2.add("_uuid");
        opselarr2.add("==");
        opselarr2.add(opselarr3);
        opselarr3.add("uuid");
        opselarr3.add(ovstbluuid);
        opselmap1.put("op", "select");
        opselmap1.put("table", "Open_vSwitch");
        opselmap1.put("columns", opselarr4);
        opselarr4.add("next_cfg");

        // Comment
        commmap1.put("comment",
                "ovs-vsctl: ovs-vsctl -vjsonrpc --db=tcp:172.16.58.170:6634 add-port br0 vnic0");
        commmap1.put("op", "comment");

        Object[] params = { "Open_vSwitch", intmap0, brmap2, portmap2,
                updtmap1, insportmap1, insintmap1, mutemap1, opselmap1,
                commmap1 };

        OvsdbMessage message = new OvsdbMessage("transact", params, "efg");
        ovsdb.sendMessage(message);
        ovsdb.readResponse(String[].class);
    }
}