1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

<?php
include('../conf/PoolConf.php');
include('../lib/Pool/Server.php');
include('../lib/Pool/Exception.php');
include('../lib/Pool/Server/Connection.php');
include('../lib/Pool/Server/Stmt.php');

# Create our worker object.
$worker= new GearmanWorker();
foreach (PoolConf::$SERVERS as $server) {
    $worker->addServer($server[0], $server[1]);
}

\Pool\Server::init();

$worker->addFunction('getConnection', 'getConnection');
$worker->addFunction('prepare', 'prepare');
$worker->addFunction('execute', 'execute');
$worker->addFunction('fetchAll', 'fetchAll');
$worker->addFunction('info', 'info');
$worker->addFunction('release', 'release');
$worker->addFunction('beginTransaction', 'beginTransaction');
$worker->addFunction('commit', 'commit');
$worker->addFunction('rollback', 'rollback');

while (1) {
    try {
        $ret = $worker->work();
        if ($worker->returnCode() != GEARMAN_SUCCESS) {
            break;
        }
    } catch (Exception $e) {
        echo $e->getMessage();
    }
}

function fetchAll($job)
{
    echo __function__."\n";
    $params = unserialize($job->workload());
    $stmtId = $params['stmt'];
    return serialize(\Pool\Server::fetchAll($stmtId));
}

function execute($job)
{
    echo __function__."\n";
    $params = unserialize($job->workload());
    $stmtId = $params['stmt'];
    $parameters = $params['parameters'];
    return \Pool\Server::execute($stmtId, $parameters);
}

function prepare($job)
{
    echo __function__."\n";
    $params = unserialize($job->workload());
    $sql = $params['sql'];
    $cid = $params['cid'];
    $key = $params['key'];
    return \Pool\Server::prepare($key, $cid, $sql);
}

function getConnection($job)
{
    echo __function__."\n";
    $key = $job->workload();

    return \Pool\Server::getConnection($key);
}

function beginTransaction($job)
{
    echo __function__."\n";
    $params = unserialize($job->workload());
    $cid = $params['cid'];
    $key = $params['key'];

    return \Pool\Server::beginTransaction($cid, $key);
}

function rollback($job)
{
    echo __function__."\n";
    $params = unserialize($job->workload());
    $cid = $params['cid'];
    $key = $params['key'];

    return \Pool\Server::rollback($cid, $key);
}

function commit($job)
{
    echo __function__."\n";
    $params = unserialize($job->workload());
    $cid = $params['cid'];
    $key = $params['key'];

    return \Pool\Server::commit($cid, $key);
}

function info($job)
{
    echo __function__."\n";
    $key = $job->workload();
    return serialize(\Pool\Server::info($key));
}

function release($job)
{
    echo __function__."\n";
    $params = unserialize($job->workload());
    $cid = $params['cid'];
    $key = $params['key'];
    return serialize(\Pool\Server::release($key, $cid));
}