Resource (REST) programming model and conventions

HTTP Method    URI                   Description
-----------    ---                   ----------------
GET            /people               list members
POST           /people               create member
GET            /people/1             retrieve member
PUT            /people/1             update member
DELETE         /people/1             delete member

/resources/<collection name>[/<member identifier>[/<path info>]]

def onList() {
    // Get configured DataManager for data access
    def data = zero.data.groovy.Manager.create('peopleDB')

    def result = data.queryArray('SELECT * FROM people')

    // Serialize list to JavaScript Object Notation format
    request.view = 'JSON'
    request.json.output = result
      
    render()
}

def onCreate() {
    // Convert entity to JSON object
    def emp = zero.json.Json.decode(request.input[])

    def data = zero.data.groovy.Manager.create('peopleDB')

    def memberId = data.insert(
                      """INSERT INTO people (firstname, lastname)
                         VALUES ($emp.firstname, $emp.lastname)""", ['id'])

    // Set a Location header with URI to the new record
    locationUri = getRequestedUri(false) + '/' + memberId
    request.headers.out.Location = locationUri
    request.status = HttpURLConnection.HTTP_NO_CONTENT
}

def onRetrieve() {
    // Member id is parsed from the path
    String id = request.params.peopleId[]

    def data = zero.data.groovy.Manager.create('peopleDB')
    def person = data.queryFirst("SELECT * FROM people WHERE id=$id")

    if(person!= null) {
        // Use ViewEngine JSON rendering
        request.view='JSON'
        request.json.output = person
     
        render()
    
    } else {
        // Error handling
        request.status = HttpURLConnection.HTTP_NOT_FOUND
        request.error.message = "username $username not found."
        request.view = 'error'
        render()
    }
}
 
def onUpdate() {
    def emp = zero.json.Json.decode(request.input[])

    def data = zero.data.groovy.Manager.create('personDB')

    data.update("UPDATE employees "
        + "SET firstname=$emp.firstname, lastname=$emp.lastname "
        + "WHERE id=$emp.id")

    request.status = HttpURLConnection.HTTP_NO_CONTENT
}
 
def onDelete() {
    def id = request.params.peopleId[]
    def data = zero.data.groovy.Manager.create('personDB')

    data.update("DELETE FROM people WHERE id=$id");

    request.status = HttpURLConnection.HTTP_NO_CONTENT
}

<?php

switch (zget('/request/method')) {
        case 'GET':
        if (zget('/event/_name') == 'list') {
                // Perform a list specific operation on the collection
        } else {
                // /event/_name = "retrieve"
                // Retrieve the resource
        }
        break;
        case 'POST':
        // do POST specific handling
        break;
        case 'DELETE':
        // do DELETE specific handling
        break;
        case 'PUT':
        // do PUT specific handling
        break;
}

?>

<?php
// Initialization common to all operations
// Get configured (as 'theDB' in zero.config) DataManager for data access
$dataManager = data_manager('theDB');
class Employees {
        function onList() {
                global $dataManager;
                // Retrieve employee records via WebSphere sMash
                $employeeRecords = dataExec($dataManager, "SELECT * FROM employees");
                // Use the zero global context to render the data as JSON
                zput('/request/view', 'JSON');
                zput('/request/json/output', $employeeRecords);
                render_view();
        }
        function onCreate() {
                global $dataManager;
                // Convert the raw JSON stream in to a PHP array
                $er = json_decode($HTTP_RAW_POST_DATA);
                $result = dataExec($dataManager, "INSERT INTO employees (username, , location, phonenumber) ". 
                "VALUES (?, ?, ?, ?, ?)", array($er['username'], $er['location'], $er['phonenumber']));
                // Set a Location header with URI to the new record
                $locationUri = get('/request/path') . "/" . $er["username"];
                zput('/request/headers/out/Location', $locationUri);
                zput('/request/status', 204);
        }
        function onRetrieve() {
                // Get configured DataManager for data access
                global $dataManager;
                // WebSphere sMash puts 'itemId' when accessing restful resources 
                $username = zget("/request/params/employeesId");
                // Retrieve employee record via WebSphere sMash
                $employeeRecord = dataQueryFirst($dataManager, "SELECT * FROM employees WHERE username=?", array($username));
                if(isset($employeeRecord)) {
                        // JSON encode employee record
                        zput('/request/headers/out/Content-Type', 'text/json');  			
                        echo json_encode($employeeRecord);
                } else {
                        // Error handling; return a custom error page
                        zput("/request/status", 404);
                        echo "username ". $username . " not found.";
                }
        }
        function onUpdate() {
                // Get configured DataManager for data access
                global $dataManager;
                // By convention, WebSphere sMash places posted text/json into the GC as a JSON object
                $er = json_decode($HTTP_RAW_POST_DATA);
                $result = dataExec($dataManager, "UPDATE employees location=?, phonenumber=? WHERE username=?",
                array($er['firstname'], $er['phonenumber'], $er['username']));
                zput("/request/status", 204);
        }
        function onDelete() {
                // Get configured DataManager for data access
                global $dataManager;
                $username = zget("/request/params/employeesId");
                // Delete employee record via WebSphere sMash
                $result = dataExec($dataManager, "DELETE FROM employees WHERE username=?", array($username));
                zput("/request/status", 204);
        }
}
?>