#!/usr/sbin/dtrace -qs

postgresql*:::command-string
{
        sqlcommand = copyinstr(arg0);
}
postgresql*:::executed-select
{
        @select[pid, "Total Selects:"] = count();
        @selectpersec[pid, "Selects/sec:"] = count();
}
postgresql*:::executed-insert
{
        @insert[pid, "Inserts Total:"] = count();
        @insertpersec[pid,"Inserts/sec:"] = count();
}

postgresql*:::executed-delete
{
        @delete[pid, "Total Deletes:"] = count();
        @deletepersec[pid, "Deletes/sec:"] = count();
}

postgresql*:::executed-update
{
        @update[pid, "Total Updates:"] = count();
        @updatepersec[pid, "Updates/sec:"] = count();
}

postgresql*:::transaction-start
{
        @start[pid, "Total Start:"] = count();
        @startpersec[pid, "Start/sec:"] = count();
}



#!/usr/sbin/dtrace -qs

postgresql*:::command-string
{
        sqlcommand = copyinstr(arg0);
}
postgresql*:::executed-select
{
        @select[pid, "Total Selects:"] = count();
        @selectpersec[pid, "Selects/sec:"] = count();
}
postgresql*:::executed-insert
{
        @insert[pid, "Inserts Total:"] = count();
        @insertpersec[pid,"Inserts/sec:"] = count();
}

postgresql*:::executed-delete
{
        @delete[pid, "Total Deletes:"] = count();
        @deletepersec[pid, "Deletes/sec:"] = count();
}

postgresql*:::executed-update
{
        @update[pid, "Total Updates:"] = count();
        @updatepersec[pid, "Updates/sec:"] = count();
}

postgresql*:::transaction-start
{
        @start[pid, "Total Start:"] = count();
        @startpersec[pid, "Start/sec:"] = count();
}


postgresql*:::transaction-abort
{
        @abort[pid, "Total Aborts:"] = count();
}

profile:::tick-1s
{
        printf("\nCommands Executed........... \n");

        printf("%s \n", sqlcommand);

        printa("%5d %20s %@15d\n", @select);
        printa("%5d %20s %@15d\n", @selectpersec);
        printa("%5d %20s %@15d\n", @insert);
        printa("%5d %20s %@15d\n", @insertpersec);
        printa("%5d %20s %@15d\n", @delete);
        printa("%5d %20s %@15d\n", @deletepersec);
        printa("%5d %20s %@15d\n", @update);
        printa("%5d %20s %@15d\n", @updatepersec);

        printf("Transactions      \n");

        printa("%5d %20s %@15d\n", @start);
        printa("%5d %20s %@15d\n", @commit);
        printa("%5d %20s %@15d\n", @abort);
        printf("\n");

        clear(@insertpersec);
        clear(@deletepersec);
        clear(@selectpersec);
        clear(@updatepersec);
        clear(@startpersec);
}