Gunther Oracle APEX und Datenbank Wiki

Diese Seite ist nicht editierbar. Sie können den Quelltext sehen, jedoch nicht verändern. Kontaktieren Sie den Administrator, wenn Sie glauben, dass hier ein Fehler vorliegt.
===== Die Befehle der Admin Konsole der Oracle NoSQL DB im eigenen Programm integrieren =====

Über die Klasse CommandServiceAPI kann auch im eigenen Programmcode auf die Befehle der Admin Konsole der NoSQL Datenbank zugegriffen werden.

=== Initialisieren ===

<code java>

..
    public static CommandServiceAPI csi = null;
    public static String adminNode = "localost";
    public static int adminPort = 5000;
..
    /**
     *  init the Command API
     */
    public static void init(String nodeName, int RMIPort) {
        log("     =============Get PerfMap Demo ==========================");
        try {
            if (csi == null) {
                csi = RegistryUtils.getAdmin(nodeName, RMIPort);
            }

        }
        catch (Exception ex) {
            log(ex.toString());
        }

    }
</code>

=== Beispiel für den Aufruf der Performance Statistik ohne den lästigen Header der Amin Konsole===

<code java>    

    /**
     * show the performance Satistik of the KStore
     */

    public static void showPerfStat() {

        log("     =============Get PerfMap Demo ==========================");
        try {
            if (csi == null) {
                init(adminNode, adminPort);
            }

            Map<ResourceId, PerfEvent> perfmap = csi.getPerfMap();

            for (PerfEvent pe : perfmap.values()) {
                System.out.println(pe.getColumnFormatted());
            }
        }
        catch (Exception ex) {
            log(ex.toString());
        }

        log("     =============Get PerfMap Demo ==========================");
    }
    
</code>

===Beispiel für die Anzeige der Topology===

<code java>    
    /**
     * show the Topology Overview of the KStore
     */
    
        public static void showTopology(){
        
        log("     =============show Part Map ==========================");
        
        try {
            
            if (csi == null) {
                init(adminNode, adminPort);
            }           
            
            Topology topo = csi.getTopology();
            PartitionMap part = topo.getPartitionMap();
           
            for (Topology.Component com :  part.getAll()) {
                System.out.println(com.toString());
            }
            for ( StorageNode sn : topo.getSortedStorageNodes() ){
                System.out.println("Read from "+ sn.getStorageNodeId() +" read :: "+sn.toString());                
            }
            
        }
        catch (Exception ex) {
            log(ex.toString());
        }

        log("     =============show Part Map ==========================");
        
    }

</code>

=== Beispiel für eine Anzeige des Status der einzelnen Nodes in einer CSV Sicht ===

<code java>

    public static void showTopologyCSV() {

        try {

            if (csi == null) {
                init(adminNode, adminPort);
            }

            // get the topo

            Topology topo = csi.getTopology();

            //register util
            RegistryUtils regUtils = new RegistryUtils(topo);

            // grep the status
            ServiceStatus status = ServiceStatus.UNREACHABLE;
            // For all Storage Nodes
            StorageNodeStatus snStatus = null;
            StorageNodeAgentAPI sna = null;

            RepNodeStatus rnStatus = null;
            RepNodeAdminAPI rna = null;
            String repRole = "MASTER";

            for (StorageNode sn : topo.getSortedStorageNodes()) {
                sna = regUtils.getStorageNodeAgent(sn.getStorageNodeId());
                snStatus = sna.ping();
                status = snStatus.getServiceStatus();
                System.out.printf("nosqlTopo=%s|%s|%s|null\n",sn.getStorageNodeId(),sn.toString(),status);

                RepGroupMap snrepgrp = topo.getRepGroupMap();
                for (RepGroup r : snrepgrp.getAll()) {
                    for (RepNode rn2 : r.getRepNodes()) {
                        rna = regUtils.getRepNodeAdmin(rn2.getResourceId());
                        rnStatus = rna.ping();
                        status = rnStatus.getServiceStatus();
                        if (sn.getStorageNodeId().equals(rn2.getStorageNodeId())) {

                            if (rnStatus.getReplicationState().isMaster()) {
                                repRole = "MASTER";
                            } else {
                                repRole = "REPLICA";
                            }

                             System.out.printf("nosqlTopo=%s|%s|%s|%s\n",rn2.toString(),r.toString(),status,repRole);
                        }
                    }
                }

            }

        } catch (Exception ex) {
            System.out.println(ex.toString());
        }

</code>

==== Version abfragen ====

Erste Version,geht über die ganze Topology, kann noch verbessert werden .-)!

<code java>
    public static void showVersion() {

        String version     = "n/a";
        String datacenter  = "n/a";
        String storeName   = "n/a";
        String numPartions = "100";

        try {

            if (csi == null) {
                init(adminNode, adminPort);
            }

            // get the topo
            Topology topo = csi.getTopology();
            
            storeName   = topo.getKVStoreName();
            numPartions = ""+topo.getPartitionMap().size();

            //register util
            RegistryUtils regUtils = new RegistryUtils(topo);
           
            RepNodeAdminAPI rna = null;
            
            KVVersion rnVersion = null;

            RepGroupMap snrepgrp = topo.getRepGroupMap();

            for (RepGroup r : snrepgrp.getAll()) {
                for (RepNode rn2 : r.getRepNodes()) {
                    rna = regUtils.getRepNodeAdmin(rn2.getResourceId());
                    rnVersion = rna.getInfo().getSoftwareVersion();
                    version = rnVersion.getNumericVersionString();
                    datacenter = topo.getDatacenter(rn2.getStorageNodeId()).getName();
                }
            }

        } catch (Exception ex) {
            System.out.println(ex.toString());
        }

        System.out.printf("Version %s| DataCenter %s| Storename %s| Anzahl Partitionen %s\n", version, datacenter,storeName,numPartions);

    }
</code>