inc/cms/cms.php.inc

<?php
/*------------------------------------------------------------------------------
--- www.netfrag.org
--- Content management functions include file.
--------------------------------------------------------------------------------
--- rabit, 01:04 27.08.2004
--- $Id: cms.php.inc,v 1.6 2004/09/10 21:40:59 rabit Exp $
------------------------------------------------------------------------------*/

//----------------------------------------------------------
//- Declaration of CMS data sources:

$i = 0;

$cms_sources = array(

 'SOURCES' => array(
  'fields' => array(
   'id' => '',
   'name' => '',
   'fieldcount' => '',
  ),
  'index' => $i++
 ),

 'contents' => array(
  'fields' => array(
   'id' => '',
   'creator_id' => '',
   'content' => '',
   'type' => '',
   'timestamp' => '',
   'description' => '',
   'keyname' => '',
   'language_id' => ''
  ),
  'index' => $i++
 ),

 'contenttypes' => array(
  'fields' => array(
   'id' => '',
   'name' => ''
  ),
  'index' => $i++
 ),

 'languages' => array(
  'fields' => array(
   'id' => '',
   'name' => '',
   'abbreviation' => ''
  ),
  'index' => $i++
 ),

);

//------------------------------------------------------------------------------

function cms_getcontent($type, $keyname, $language_id = 0) {

  $sql = "SELECT contents.content, contents.description, UNIX_TIMESTAMP(contents.timestamp), languages.name, users.name, contents.keyname FROM contents, languages, users WHERE contents.type='$type' AND contents.keyname='$keyname'" . ($language_id ? " AND languages.id='$language_id'" : '') . " AND users.id=contents.creator_id AND languages.id=contents.language_id LIMIT 0,1;";

  $res = mysql_query($sql);
  if(!$res) return false;

  $row = mysql_fetch_row($res);

  $contentdata = array(
   'content' => $row[0],
   'description' => $row[1],
   'unixtime' => $row[2],
   'language_name' => $row[3],
   'creator_name' => $row[4],
   'keyname' => $row[5],
  );

  return $contentdata;

}

//----------------------------------------------------------

function cms_getlist(
 $types, $keynames, $daterange = '', $languageids = '', $languages = '') {

  $sql = "SELECT contents.id, contents.description, UNIX_TIMESTAMP(contents.timestamp), languages.id, languages.name, users.name FROM contents, languages, users WHERE contents.type='$types' AND contents.keyname='$keynames' AND users.id=contents.creator_id AND languages.id=contents.language_id;";

  $res = common_dbc_query($sql);

  $rowcount = 0;

  while($row = mysql_fetch_row($res)) $rows[$rowcount++] = $row;

  return $rows;

}

//----------------------------------------------------------

function cms_getindex($type) {

  $sql = "SELECT contents.id, contents.keyname, contents.description, UNIX_TIMESTAMP(contents.timestamp) as timestamp, languages.id, languages.name as lang, users.name as creator FROM contents, languages, users WHERE contents.type='$type' AND users.id=contents.creator_id AND languages.id=contents.language_id;";

  $res = common_dbc_query($sql);

  $rowcount = 0;

  while($row = mysql_fetch_assoc($res)) $rows[$rowcount++] = $row;

  return $rows;

}

//----------------------------------------------------------

function cms_query($nqlquery, &$response) {

global $cms_sources;

//------------------

$operations = array(
 'GET' => 0
);

//------------------

  cms_preparsenqlquery($nqlquery, $preparseresponse);

  $subsegcount = count($preparseresponse[1]);//['subsegmentcount'];

  $querydata = array(
   'count' => '',
   'fieldlist' => array(),
   'first' => '',
   'get_what' => '',
   'locked' => '',
   'operation' => '',
   'orderby' => '',
   'query' => $preparseresponse[0]['formattednql'],
   'source' => '',
   'with' => array(),
  );

  if(!$querydata['query']) {

    $response = cms_create_response('no_query', null, null, $querydata);
    return false;

  }

  $subseg = 0;
  $querydata['operation'] = $preparseresponse[1][$subseg][0];
  $pcount = count($preparseresponse[1][$subseg++]);

  if($pcount != 1) {

    $response = cms_create_response('syntax', null, null, $querydata);
    return false;

  }

  if(isset($operations[$querydata['operation']])) {

    $operationindex = $operations[$querydata['operation']];

  } else {

    $response = cms_create_response('illegal_op', null, null, $querydata);
    return false;

  }

  if($subseg == $subsegcount) {

    $response = cms_create_response('no_params', null, null, $querydata);
    return false;

  }

  switch($operationindex) {

    case 0: // "GET"

      $fieldlist = $preparseresponse[1][$subseg++];
      $pcount = count($fieldlist);

      if($subseg == $subsegcount) {

        $response = cms_create_response('no_sourcedef', null, null, $querydata);
        return false;

      }

      $querydata['get_what'] = $fieldlist[0];
      $querydata['fieldlist'] = array();

      switch($querydata['get_what']) {

        case 'COUNT':
        case 'FIELDNAMES':
        case '*':

          if($pcount != 1) {

            $response = cms_create_response('syntax', null, null, $querydata);
            return false;

          }

          break;

        case 'FROM':

          $response = cms_create_response('no_fielddef', null, null, $querydata);
          return false;

        default:

          $querydata['fieldlist'] = $fieldlist;
          $querydata['get_what'] = 'FIELD';

      }

      $from = $preparseresponse[1][$subseg][0];
      $pcount = count($preparseresponse[1][$subseg++]);

      if($from != 'FROM') {

        $response = cms_create_response('no_from', null, null, $querydata);
        return false;

      }

      if($pcount != 1) {

        $response = cms_create_response('syntax', null, null, $querydata);
        return false;

      }

      if($subseg == $subsegcount) {

        $response = cms_create_response('no_source', null, null, $querydata);
        return false;

      }

      $querydata['source'] = $preparseresponse[1][$subseg][0];
      $pcount = count($preparseresponse[1][$subseg++]);

      if($pcount != 1) {

        $response = cms_create_response('syntax', null, null, $querydata);
        return false;

      }

      if(isset($cms_sources[$querydata['source']])) {

        $sourcedata = $cms_sources[$querydata['source']];
//        $sourceindex = $sourcedata['index'];
        $sourcefields = $sourcedata['fields'];

      } else {

        $response = cms_create_response('illegal_source', null, null, $querydata);
        return false;

      }

      if($querydata['get_what'] == 'FIELDNAMES' || $querydata['get_what'] == '*') {

        $querydata['fieldlist'] = array_keys($sourcedata['fields']);

      }

$getparamdata = array(
 'WITH' => '',
 'FIRST' => '',
 'COUNT' => '',
 'ORDERBY' => '',
 'LOCKED' => '',
);
//$getparams = array_keys($getparamdata);

      $currentparam = 0;
      $paramdata = $getparamdata;

      while($subseg < $subsegcount) {

        $segment = $preparseresponse[1][$subseg++];
        $pcount = count($segment);
        $param = $segment[0];

        if($pcount != 1) {

          $response = cms_create_response('syntax', null, null, $querydata);
          return false;

        }

        if(!isset($paramdata[$param])) {

          $response = cms_create_response('illegal_param', null, null, $querydata);
          return false;

        } else if($paramdata[$param]) {

          $response = cms_create_response('double_param', null, null, $querydata);
          return false;

        }

        $paramdata[$param] = true;

        switch($param) {

          case 'COUNT':

            if($subseg == $subsegcount) {

              $response = cms_create_response('param_value', null, null, $querydata);
              return false;

            }

            if($subseg == $subsegcount) {

              $response = cms_create_response('param_value', null, null, $querydata);
              return false;

            }

            $segment = $preparseresponse[1][$subseg++];
            $pcount = count($segment);
            $count = $segment[0];

            if($pcount != 1 || !is_numeric($count)) {

              $response = cms_create_response('syntax', null, null, $querydata);
              return false;

            }

            $querydata['count'] = $count;

            break;

          case 'FIRST':

            if($subseg == $subsegcount) {

              $response = cms_create_response('param_value', null, null, $querydata);
              return false;

            }

            if($subseg == $subsegcount) {

              $response = cms_create_response('param_value', null, null, $querydata);
              return false;

            }

            $segment = $preparseresponse[1][$subseg++];
            $pcount = count($segment);
            $first = $segment[0];

            if($pcount != 1 || !is_numeric($first)) {

              $response = cms_create_response('syntax', null, null, $querydata);
              return false;

            }

            $querydata['first'] = $first;

            break;

          case 'LOCKED':

            $querydata['locked'] = true;

            if($querydata['get_what'] == 'COUNT' || $querydata['get_what'] == 'FIELDNAMES') {

              $response = cms_create_response('locked', null, null, $querydata);
              return false;

            }

            break;

          case 'ORDERBY':

            if($subseg == $subsegcount) {

              $response = cms_create_response('param_value', null, null, $querydata);
              return false;

            }

            $segment = $preparseresponse[1][$subseg++];
            $pcount = count($segment);
            $fieldname = $segment[0];

            if($pcount != 1) {

              $response = cms_create_response('syntax', null, null, $querydata);
              return false;

            }

            if(!isset($sourcefields[$fieldname])) {

              $response = cms_create_response('illegal_field', null, null, $querydata);
              return false;

            }

            $querydata['orderby'] = $fieldname;

            break;

          case 'WITH':

            if($subseg == $subsegcount) {

              $response = cms_create_response('param_value', null, null, $querydata);
              return false;

            }

            $segment = $preparseresponse[1][$subseg++];
            $pcount = count($segment);
            $fieldname = $segment[0];

            if($pcount != 1) {

              $response = cms_create_response('syntax', null, null, $querydata);
              return false;

            }

            if(!isset($sourcefields[$fieldname])) {

              $response = cms_create_response('illegal_field', null, null, $querydata);
              return false;

            }

            if($subseg == $subsegcount) {

              $response = cms_create_response('param_value', null, null, $querydata);
              return false;

            }

            $fieldvalues = $preparseresponse[1][$subseg++];
            array_push($querydata['with'], array($fieldname, $fieldvalues));

            break;

        }

      }

      return cms_perform_get($querydata, $response);

  }

}

//----------------------------------------------------------

function cms_perform_get($querydata, &$response) {

global $cms_sources;

  $sourcedata = $cms_sources[$querydata['source']];
  $sourcefields = $sourcedata['fields'];

  for($f = 0; $f < count($querydata['fieldlist']); $f++) {

    if(!isset($sourcefields[$querydata['fieldlist'][$f]])) {

      $response = cms_create_response('illegal_field', null, null, $querydata);
      return false;

    }

  }

  $fieldnamelist = $querydata['fieldlist'];
  $fieldnames = join($fieldnamelist, ', ');

  $resultlist = array();

  if($querydata['get_what'] == 'COUNT') {

    $fieldnamelist = array('COUNT');

  }

  if($querydata['get_what'] == 'FIELDNAMES') {

    $resultlist = null;

  } else switch($querydata['source']) {

    case 'SOURCES':

      if($querydata['get_what'] == 'COUNT') {

        $resultlist[0][0] = count($cms_sources);
        break;

      }

      while(list($key, $sourcedata) = each($cms_sources)) {

        $row = array(
         'id' => $sourcedata['index'] + 1,
         'name' => $key,
         'fieldcount' => count($sourcedata['fields']),
        );

        $resrow = array();
        reset($fieldnamelist);

        while(list($i, $fieldname) = each($fieldnamelist))
         array_push($resrow, $row[$fieldname]);

        array_push($resultlist, $resrow);

      }

      break;

    // By default the db is used as data source:
    default:

      if($querydata['get_what'] == 'COUNT') {

        $fieldnames = 'COUNT(id)';

      }

      $limit = (
       (($querydata['count'] > 0) || ($querydata['first'] != '')) ?
       ' LIMIT ' . ($querydata['first'] > 0 ? $querydata['first'] - 1 : 0) . ',' .
       ($querydata['count'] > 0 ? $querydata['count'] : -1) : '');

      $order = (
       $querydata['orderby'] != '' ? ' ORDER BY ' . $querydata['orderby'] . ' DESC' : '');

      $where = '';

      while(list($i, $item) = each($querydata['with'])) {

        $values = $item[1];

        while(list($j, $value) = each($values))
         $where .= ($j ? ' OR' : '') . ' ' . $item[0] . '=\'' . $value . '\'';

      }

      if($where) $where = ' WHERE' . $where;

      $sql = 'SELECT ' . $fieldnames . ' FROM ' . $querydata['source'] .
       $where . $order . $limit . ';';

      #echo $sql;

      $res = common_dbc_query($sql);

      //if(!$res) ...

      while($resrow = mysql_fetch_row($res)) array_push($resultlist, $resrow);

  }

  $response = cms_create_response('no_error', $resultlist, $fieldnamelist, $querydata);
  return true;

}

//----------------------------------------------------------

function cms_preparsenqlquery($nqlquery, &$response) {

  $querysubsegs = preg_split('/[\s,]+/', $nqlquery, -1,
   PREG_SPLIT_NO_EMPTY | PREG_SPLIT_OFFSET_CAPTURE);

  $segcount = count($querysubsegs);

  while(list($i, $item) = each($querysubsegs)) {

    $pos = $item[1];
    $querysubsegs[$i][2] = strlen($item[0]);

    if($i < ($segcount - 1)) {

      $endpos = $pos + $querysubsegs[$i][2];
      $delim = substr($nqlquery, $endpos, $querysubsegs[$i + 1][1] - $endpos);

    } else $delim = substr($nqlquery, $pos + $querysubsegs[$i][2]);

    array_push($querysubsegs[$i], trim($delim));

  }

  $i = 0;

  $formattednql = '';
  $preparseresult = array();
  $listitems = array();
  $lastitem = null;
  $listcount = 0;

  while($i < $segcount) {

    $item = $querysubsegs[$i];
    $formattednql .= ($i ? ' ' : '') . $item[0]. $item[3];

    if($item[3] == ',') {

      array_push($listitems, $item[0]);

    } else {

      if($listitems) {

        array_push($listitems, $item[0]);
        array_push($preparseresult, $listitems);
        $listitems = array();
        $listcount++;

      } else array_push($preparseresult, array($item[0]));

    }

//    $lastitem = $item;
    $i++;

  }

  $response = array(

   array(
    'formattednql' => $formattednql,
//    'subsegmentcount' => $i,
    'sublistcount' => $listcount
   ),

   $preparseresult

  );

}

//----------------------------------------------------------

function cms_create_response(
 $errorkey, $resultlist, $columnnames, $querydata) {

//------------------

$i = 0;

$errors = array(
 'no_error' => array(
  $i++, 'No error'
 ),
 'no_query' => array(
  $i++, 'Empty query',
 ),
 'syntax' => array(
  $i++, 'Query syntax error',
 ),
 'illegal_op' => array(
  $i++, 'Illegal base operation',
 ),
 'no_params' => array(
  $i++, 'Operation parameters missing',
 ),
 'no_fielddef' => array(
  $i++, 'Field definition missing',
 ),
 'no_sourcedef' => array(
  $i++, 'Source definition missing',
 ),
 'no_from' => array(
  $i++, 'Source declarator missing',
 ),
 'no_source' => array(
  $i++, 'Source name missing',
 ),
 'illegal_source' => array(
  $i++, 'Illegal data source name',
 ),
 'illegal_field' => array(
  $i++, 'Illegal field name for data source',
 ),
 'illegal_param' => array(
  $i++, 'Illegal parameter name',
 ),
 'double_param' => array(
  $i++, 'Illegal double parameter',
 ),
 'locked' => array(
  $i++, 'Illegal use of LOCKED parameter',
 ),
 'param_value' => array(
  $i++, 'Parameter value missing',
 ),
);

//------------------

  $response = array(

   // Result information:
   0 => array(
    'columncount' => count($columnnames),
    'error' => $errors[$errorkey][0],
    'errortext' => $errors[$errorkey][1],
    'firstrow' => $querydata['first'],
    'get_what' => $querydata['get_what'],
    'operation' => $querydata['operation'],
    'query' => $querydata['query'],
    'rowcount' => count($resultlist),
    'source' => $querydata['source'],
    'all' => $querydata
   ),

   // Result list:
   1 => $resultlist,

   // Column names:
   2 => $columnnames

  );

  return $response;

}

//------------------------------------------------------------------------------

?>
1	rabit	1.1	<?php
2			/*------------------------------------------------------------------------------
3			--- www.netfrag.org
4			--- Content management functions include file.
5			--------------------------------------------------------------------------------
6			--- rabit, 01:04 27.08.2004
7	rabit	1.7	--- $Id: cms.php.inc,v 1.6 2004/09/10 21:40:59 rabit Exp $
8	rabit	1.1	------------------------------------------------------------------------------*/
9
10	rabit	1.6	//----------------------------------------------------------
11			//- Declaration of CMS data sources:
12
13			$i = 0;
14
15			$cms_sources = array(
16
17			'SOURCES' => array(
18			'fields' => array(
19			'id' => '',
20			'name' => '',
21			'fieldcount' => '',
22			),
23			'index' => $i++
24			),
25
26			'contents' => array(
27			'fields' => array(
28			'id' => '',
29			'creator_id' => '',
30			'content' => '',
31			'type' => '',
32			'timestamp' => '',
33			'description' => '',
34			'keyname' => '',
35			'language_id' => ''
36			),
37			'index' => $i++
38			),
39
40			'contenttypes' => array(
41			'fields' => array(
42			'id' => '',
43			'name' => ''
44			),
45			'index' => $i++
46			),
47
48			'languages' => array(
49			'fields' => array(
50			'id' => '',
51			'name' => '',
52			'abbreviation' => ''
53			),
54			'index' => $i++
55			),
56
57			);
58
59			//------------------------------------------------------------------------------
60
61	rabit	1.1	function cms_getcontent($type, $keyname, $language_id = 0) {
62
63	joko	1.4	$sql = "SELECT contents.content, contents.description, UNIX_TIMESTAMP(contents.timestamp), languages.name, users.name, contents.keyname FROM contents, languages, users WHERE contents.type='$type' AND contents.keyname='$keyname'" . ($language_id ? " AND languages.id='$language_id'" : '') . " AND users.id=contents.creator_id AND languages.id=contents.language_id LIMIT 0,1;";
64	rabit	1.1
65			$res = mysql_query($sql);
66			if(!$res) return false;
67
68			$row = mysql_fetch_row($res);
69
70			$contentdata = array(
71			'content' => $row[0],
72			'description' => $row[1],
73			'unixtime' => $row[2],
74			'language_name' => $row[3],
75	joko	1.4	'creator_name' => $row[4],
76			'keyname' => $row[5],
77	rabit	1.1	);
78
79			return $contentdata;
80
81			}
82	rabit	1.3
83			//----------------------------------------------------------
84
85	rabit	1.6	function cms_getlist(
86			$types, $keynames, $daterange = '', $languageids = '', $languages = '') {
87	rabit	1.3
88			$sql = "SELECT contents.id, contents.description, UNIX_TIMESTAMP(contents.timestamp), languages.id, languages.name, users.name FROM contents, languages, users WHERE contents.type='$types' AND contents.keyname='$keynames' AND users.id=contents.creator_id AND languages.id=contents.language_id;";
89
90	rabit	1.5	$res = common_dbc_query($sql);
91	rabit	1.3
92			$rowcount = 0;
93
94			while($row = mysql_fetch_row($res)) $rows[$rowcount++] = $row;
95	joko	1.4
96			return $rows;
97
98			}
99
100			//----------------------------------------------------------
101
102			function cms_getindex($type) {
103
104	rabit	1.5	$sql = "SELECT contents.id, contents.keyname, contents.description, UNIX_TIMESTAMP(contents.timestamp) as timestamp, languages.id, languages.name as lang, users.name as creator FROM contents, languages, users WHERE contents.type='$type' AND users.id=contents.creator_id AND languages.id=contents.language_id;";
105	joko	1.4
106	rabit	1.5	$res = common_dbc_query($sql);
107	joko	1.4
108			$rowcount = 0;
109
110			while($row = mysql_fetch_assoc($res)) $rows[$rowcount++] = $row;
111	rabit	1.3
112			return $rows;
113
114			}
115
116			//----------------------------------------------------------
117	rabit	1.1
118	rabit	1.6	function cms_query($nqlquery, &$response) {
119
120			global $cms_sources;
121	rabit	1.5
122			//------------------
123
124	rabit	1.6	$operations = array(
125			'GET' => 0
126	rabit	1.5	);
127
128			//------------------
129
130	rabit	1.6	cms_preparsenqlquery($nqlquery, $preparseresponse);
131
132	rabit	1.7	$subsegcount = count($preparseresponse[1]);//['subsegmentcount'];
133	rabit	1.6
134			$querydata = array(
135	rabit	1.7	'count' => '',
136			'fieldlist' => array(),
137			'first' => '',
138			'get_what' => '',
139			'locked' => '',
140			'operation' => '',
141			'orderby' => '',
142	rabit	1.6	'query' => $preparseresponse[0]['formattednql'],
143	rabit	1.7	'source' => '',
144			'with' => array(),
145	rabit	1.6	);
146	rabit	1.5
147	rabit	1.6	if(!$querydata['query']) {
148	rabit	1.5
149	rabit	1.6	$response = cms_create_response('no_query', null, null, $querydata);
150			return false;
151	rabit	1.5
152	rabit	1.6	}
153	rabit	1.5
154	rabit	1.6	$subseg = 0;
155	rabit	1.7	$querydata['operation'] = $preparseresponse[1][$subseg][0];
156			$pcount = count($preparseresponse[1][$subseg++]);
157
158			if($pcount != 1) {
159
160			$response = cms_create_response('syntax', null, null, $querydata);
161			return false;
162
163			}
164	rabit	1.5
165	rabit	1.6	if(isset($operations[$querydata['operation']])) {
166	rabit	1.5
167	rabit	1.6	$operationindex = $operations[$querydata['operation']];
168	rabit	1.5
169			} else {
170
171	rabit	1.6	$response = cms_create_response('illegal_op', null, null, $querydata);
172			return false;
173	rabit	1.5
174	rabit	1.6	}
175
176			if($subseg == $subsegcount) {
177
178			$response = cms_create_response('no_params', null, null, $querydata);
179	rabit	1.5	return false;
180
181			}
182
183			switch($operationindex) {
184
185	rabit	1.6	case 0: // "GET"
186
187			$fieldlist = $preparseresponse[1][$subseg++];
188	rabit	1.7	$pcount = count($fieldlist);
189	rabit	1.6
190			if($subseg == $subsegcount) {
191
192			$response = cms_create_response('no_sourcedef', null, null, $querydata);
193			return false;
194
195			}
196
197	rabit	1.7	$querydata['get_what'] = $fieldlist[0];
198	rabit	1.6	$querydata['fieldlist'] = array();
199
200	rabit	1.7	switch($querydata['get_what']) {
201	rabit	1.6
202			case 'COUNT':
203			case 'FIELDNAMES':
204			case '*':
205	rabit	1.5
206	rabit	1.7	if($pcount != 1) {
207
208			$response = cms_create_response('syntax', null, null, $querydata);
209			return false;
210
211			}
212
213	rabit	1.6	break;
214	rabit	1.5
215	rabit	1.6	case 'FROM':
216	rabit	1.5
217	rabit	1.6	$response = cms_create_response('no_fielddef', null, null, $querydata);
218			return false;
219	rabit	1.5
220	rabit	1.6	default:
221	rabit	1.5
222	rabit	1.7	$querydata['fieldlist'] = $fieldlist;
223			$querydata['get_what'] = 'FIELD';
224	rabit	1.5
225			}
226	rabit	1.6
227	rabit	1.7	$from = $preparseresponse[1][$subseg][0];
228			$pcount = count($preparseresponse[1][$subseg++]);
229	rabit	1.5
230	rabit	1.6	if($from != 'FROM') {
231	rabit	1.5
232	rabit	1.6	$response = cms_create_response('no_from', null, null, $querydata);
233			return false;
234	rabit	1.5
235	rabit	1.6	}
236	rabit	1.5
237	rabit	1.7	if($pcount != 1) {
238
239			$response = cms_create_response('syntax', null, null, $querydata);
240			return false;
241
242			}
243
244	rabit	1.6	if($subseg == $subsegcount) {
245	rabit	1.5
246	rabit	1.6	$response = cms_create_response('no_source', null, null, $querydata);
247	rabit	1.5	return false;
248
249			}
250
251	rabit	1.7	$querydata['source'] = $preparseresponse[1][$subseg][0];
252			$pcount = count($preparseresponse[1][$subseg++]);
253
254			if($pcount != 1) {
255
256			$response = cms_create_response('syntax', null, null, $querydata);
257			return false;
258
259			}
260	rabit	1.5
261	rabit	1.6	if(isset($cms_sources[$querydata['source']])) {
262	rabit	1.5
263	rabit	1.6	$sourcedata = $cms_sources[$querydata['source']];
264	rabit	1.7	// $sourceindex = $sourcedata['index'];
265			$sourcefields = $sourcedata['fields'];
266	rabit	1.5
267	rabit	1.6	} else {
268
269			$response = cms_create_response('illegal_source', null, null, $querydata);
270			return false;
271	rabit	1.5
272	rabit	1.6	}
273	rabit	1.5
274	rabit	1.7	if($querydata['get_what'] == 'FIELDNAMES' \|\| $querydata['get_what'] == '*') {
275	rabit	1.5
276	rabit	1.6	$querydata['fieldlist'] = array_keys($sourcedata['fields']);
277	rabit	1.5
278			}
279
280	rabit	1.7	$getparamdata = array(
281			'WITH' => '',
282			'FIRST' => '',
283			'COUNT' => '',
284			'ORDERBY' => '',
285			'LOCKED' => '',
286			);
287			//$getparams = array_keys($getparamdata);
288
289			$currentparam = 0;
290			$paramdata = $getparamdata;
291
292			while($subseg < $subsegcount) {
293
294			$segment = $preparseresponse[1][$subseg++];
295			$pcount = count($segment);
296			$param = $segment[0];
297
298			if($pcount != 1) {
299
300			$response = cms_create_response('syntax', null, null, $querydata);
301			return false;
302
303			}
304
305			if(!isset($paramdata[$param])) {
306
307			$response = cms_create_response('illegal_param', null, null, $querydata);
308			return false;
309
310			} else if($paramdata[$param]) {
311
312			$response = cms_create_response('double_param', null, null, $querydata);
313			return false;
314
315			}
316
317			$paramdata[$param] = true;
318
319			switch($param) {
320
321			case 'COUNT':
322
323			if($subseg == $subsegcount) {
324
325			$response = cms_create_response('param_value', null, null, $querydata);
326			return false;
327
328			}
329
330			if($subseg == $subsegcount) {
331
332			$response = cms_create_response('param_value', null, null, $querydata);
333			return false;
334
335			}
336
337			$segment = $preparseresponse[1][$subseg++];
338			$pcount = count($segment);
339			$count = $segment[0];
340
341			if($pcount != 1 \|\| !is_numeric($count)) {
342
343			$response = cms_create_response('syntax', null, null, $querydata);
344			return false;
345
346			}
347
348			$querydata['count'] = $count;
349
350			break;
351
352			case 'FIRST':
353
354			if($subseg == $subsegcount) {
355
356			$response = cms_create_response('param_value', null, null, $querydata);
357			return false;
358
359			}
360
361			if($subseg == $subsegcount) {
362
363			$response = cms_create_response('param_value', null, null, $querydata);
364			return false;
365
366			}
367
368			$segment = $preparseresponse[1][$subseg++];
369			$pcount = count($segment);
370			$first = $segment[0];
371
372			if($pcount != 1 \|\| !is_numeric($first)) {
373
374			$response = cms_create_response('syntax', null, null, $querydata);
375			return false;
376
377			}
378
379			$querydata['first'] = $first;
380
381			break;
382
383			case 'LOCKED':
384
385			$querydata['locked'] = true;
386
387			if($querydata['get_what'] == 'COUNT' \|\| $querydata['get_what'] == 'FIELDNAMES') {
388
389			$response = cms_create_response('locked', null, null, $querydata);
390			return false;
391
392			}
393
394			break;
395
396			case 'ORDERBY':
397
398			if($subseg == $subsegcount) {
399
400			$response = cms_create_response('param_value', null, null, $querydata);
401			return false;
402
403			}
404
405			$segment = $preparseresponse[1][$subseg++];
406			$pcount = count($segment);
407			$fieldname = $segment[0];
408
409			if($pcount != 1) {
410
411			$response = cms_create_response('syntax', null, null, $querydata);
412			return false;
413
414			}
415
416			if(!isset($sourcefields[$fieldname])) {
417
418			$response = cms_create_response('illegal_field', null, null, $querydata);
419			return false;
420
421			}
422
423			$querydata['orderby'] = $fieldname;
424
425			break;
426
427			case 'WITH':
428
429			if($subseg == $subsegcount) {
430
431			$response = cms_create_response('param_value', null, null, $querydata);
432			return false;
433
434			}
435
436			$segment = $preparseresponse[1][$subseg++];
437			$pcount = count($segment);
438			$fieldname = $segment[0];
439
440			if($pcount != 1) {
441
442			$response = cms_create_response('syntax', null, null, $querydata);
443			return false;
444
445			}
446
447			if(!isset($sourcefields[$fieldname])) {
448
449			$response = cms_create_response('illegal_field', null, null, $querydata);
450			return false;
451
452			}
453
454			if($subseg == $subsegcount) {
455
456			$response = cms_create_response('param_value', null, null, $querydata);
457			return false;
458
459			}
460
461			$fieldvalues = $preparseresponse[1][$subseg++];
462			array_push($querydata['with'], array($fieldname, $fieldvalues));
463
464			break;
465
466			}
467
468			}
469
470	rabit	1.6	return cms_perform_get($querydata, $response);
471
472			}
473
474			}
475
476			//----------------------------------------------------------
477
478			function cms_perform_get($querydata, &$response) {
479	rabit	1.5
480	rabit	1.6	global $cms_sources;
481
482			$sourcedata = $cms_sources[$querydata['source']];
483			$sourcefields = $sourcedata['fields'];
484
485			for($f = 0; $f < count($querydata['fieldlist']); $f++) {
486
487			if(!isset($sourcefields[$querydata['fieldlist'][$f]])) {
488
489			$response = cms_create_response('illegal_field', null, null, $querydata);
490			return false;
491
492			}
493	rabit	1.5
494	rabit	1.6	}
495	rabit	1.5
496	rabit	1.6	$fieldnamelist = $querydata['fieldlist'];
497			$fieldnames = join($fieldnamelist, ', ');
498	rabit	1.5
499	rabit	1.6	$resultlist = array();
500	rabit	1.5
501	rabit	1.7	if($querydata['get_what'] == 'COUNT') {
502	rabit	1.5
503	rabit	1.6	$fieldnamelist = array('COUNT');
504	rabit	1.5
505	rabit	1.6	}
506	rabit	1.5
507	rabit	1.7	if($querydata['get_what'] == 'FIELDNAMES') {
508	rabit	1.5
509	rabit	1.6	$resultlist = null;
510	rabit	1.5
511	rabit	1.6	} else switch($querydata['source']) {
512	rabit	1.5
513	rabit	1.6	case 'SOURCES':
514	rabit	1.5
515	rabit	1.7	if($querydata['get_what'] == 'COUNT') {
516	rabit	1.5
517	rabit	1.6	$resultlist[0][0] = count($cms_sources);
518			break;
519	rabit	1.5
520			}
521
522	rabit	1.6	while(list($key, $sourcedata) = each($cms_sources)) {
523	rabit	1.5
524	rabit	1.6	$row = array(
525			'id' => $sourcedata['index'] + 1,
526			'name' => $key,
527			'fieldcount' => count($sourcedata['fields']),
528			);
529	rabit	1.5
530	rabit	1.6	$resrow = array();
531			reset($fieldnamelist);
532	rabit	1.5
533	rabit	1.6	while(list($i, $fieldname) = each($fieldnamelist))
534			array_push($resrow, $row[$fieldname]);
535	rabit	1.5
536	rabit	1.6	array_push($resultlist, $resrow);
537	rabit	1.5
538	rabit	1.6	}
539	rabit	1.5
540	rabit	1.6	break;
541	rabit	1.5
542	rabit	1.6	// By default the db is used as data source:
543			default:
544	rabit	1.5
545	rabit	1.7	if($querydata['get_what'] == 'COUNT') {
546	rabit	1.5
547	rabit	1.6	$fieldnames = 'COUNT(id)';
548	rabit	1.5
549			}
550
551	rabit	1.7	$limit = (
552			(($querydata['count'] > 0) \|\| ($querydata['first'] != '')) ?
553			' LIMIT ' . ($querydata['first'] > 0 ? $querydata['first'] - 1 : 0) . ',' .
554			($querydata['count'] > 0 ? $querydata['count'] : -1) : '');
555
556			$order = (
557			$querydata['orderby'] != '' ? ' ORDER BY ' . $querydata['orderby'] . ' DESC' : '');
558
559			$where = '';
560
561			while(list($i, $item) = each($querydata['with'])) {
562
563			$values = $item[1];
564
565			while(list($j, $value) = each($values))
566			$where .= ($j ? ' OR' : '') . ' ' . $item[0] . '=\'' . $value . '\'';
567
568			}
569
570			if($where) $where = ' WHERE' . $where;
571
572			$sql = 'SELECT ' . $fieldnames . ' FROM ' . $querydata['source'] .
573			$where . $order . $limit . ';';
574
575			#echo $sql;
576
577	rabit	1.6	$res = common_dbc_query($sql);
578
579			//if(!$res) ...
580
581			while($resrow = mysql_fetch_row($res)) array_push($resultlist, $resrow);
582
583			}
584
585			$response = cms_create_response('no_error', $resultlist, $fieldnamelist, $querydata);
586			return true;
587
588			}
589
590			//----------------------------------------------------------
591
592			function cms_preparsenqlquery($nqlquery, &$response) {
593
594			$querysubsegs = preg_split('/[\s,]+/', $nqlquery, -1,
595			PREG_SPLIT_NO_EMPTY \| PREG_SPLIT_OFFSET_CAPTURE);
596
597			$segcount = count($querysubsegs);
598	rabit	1.5
599	rabit	1.6	while(list($i, $item) = each($querysubsegs)) {
600	rabit	1.5
601	rabit	1.6	$pos = $item[1];
602			$querysubsegs[$i][2] = strlen($item[0]);
603
604			if($i < ($segcount - 1)) {
605
606			$endpos = $pos + $querysubsegs[$i][2];
607			$delim = substr($nqlquery, $endpos, $querysubsegs[$i + 1][1] - $endpos);
608
609			} else $delim = substr($nqlquery, $pos + $querysubsegs[$i][2]);
610
611			array_push($querysubsegs[$i], trim($delim));
612
613			}
614	rabit	1.5
615	rabit	1.6	$i = 0;
616	rabit	1.5
617	rabit	1.6	$formattednql = '';
618			$preparseresult = array();
619			$listitems = array();
620			$lastitem = null;
621			$listcount = 0;
622	rabit	1.5
623	rabit	1.6	while($i < $segcount) {
624	rabit	1.5
625	rabit	1.6	$item = $querysubsegs[$i];
626			$formattednql .= ($i ? ' ' : '') . $item[0]. $item[3];
627	rabit	1.5
628	rabit	1.6	if($item[3] == ',') {
629	rabit	1.5
630	rabit	1.6	array_push($listitems, $item[0]);
631	rabit	1.5
632	rabit	1.6	} else {
633	rabit	1.5
634	rabit	1.6	if($listitems) {
635	rabit	1.5
636	rabit	1.6	array_push($listitems, $item[0]);
637			array_push($preparseresult, $listitems);
638			$listitems = array();
639			$listcount++;
640	rabit	1.5
641	rabit	1.6	} else array_push($preparseresult, array($item[0]));
642	rabit	1.5
643	rabit	1.6	}
644	rabit	1.5
645	rabit	1.6	// $lastitem = $item;
646			$i++;
647	rabit	1.5
648			}
649
650	rabit	1.6	$response = array(
651
652			array(
653			'formattednql' => $formattednql,
654	rabit	1.7	// 'subsegmentcount' => $i,
655	rabit	1.6	'sublistcount' => $listcount
656			),
657
658			$preparseresult
659
660			);
661
662	rabit	1.5	}
663
664			//----------------------------------------------------------
665
666	rabit	1.7	function cms_create_response(
667			$errorkey, $resultlist, $columnnames, $querydata) {
668	rabit	1.5
669			//------------------
670
671	rabit	1.6	$i = 0;
672
673			$errors = array(
674			'no_error' => array(
675			$i++, 'No error'
676			),
677			'no_query' => array(
678			$i++, 'Empty query',
679			),
680	rabit	1.7	'syntax' => array(
681			$i++, 'Query syntax error',
682			),
683	rabit	1.6	'illegal_op' => array(
684			$i++, 'Illegal base operation',
685			),
686			'no_params' => array(
687			$i++, 'Operation parameters missing',
688			),
689			'no_fielddef' => array(
690			$i++, 'Field definition missing',
691			),
692			'no_sourcedef' => array(
693			$i++, 'Source definition missing',
694			),
695			'no_from' => array(
696			$i++, 'Source declarator missing',
697			),
698			'no_source' => array(
699			$i++, 'Source name missing',
700			),
701			'illegal_source' => array(
702			$i++, 'Illegal data source name',
703			),
704			'illegal_field' => array(
705			$i++, 'Illegal field name for data source',
706			),
707	rabit	1.7	'illegal_param' => array(
708			$i++, 'Illegal parameter name',
709			),
710			'double_param' => array(
711			$i++, 'Illegal double parameter',
712			),
713			'locked' => array(
714			$i++, 'Illegal use of LOCKED parameter',
715			),
716			'param_value' => array(
717			$i++, 'Parameter value missing',
718			),
719	rabit	1.5	);
720
721			//------------------
722
723			$response = array(
724
725			// Result information:
726			0 => array(
727	rabit	1.7	'columncount' => count($columnnames),
728	rabit	1.6	'error' => $errors[$errorkey][0],
729			'errortext' => $errors[$errorkey][1],
730	rabit	1.7	'firstrow' => $querydata['first'],
731			'get_what' => $querydata['get_what'],
732			'operation' => $querydata['operation'],
733			'query' => $querydata['query'],
734	rabit	1.5	'rowcount' => count($resultlist),
735	rabit	1.6	'source' => $querydata['source'],
736	rabit	1.7	'all' => $querydata
737	rabit	1.5	),
738
739			// Result list:
740			1 => $resultlist,
741
742			// Column names:
743			2 => $columnnames
744
745			);
746
747			return $response;
748
749			}
750
751	rabit	1.1	//------------------------------------------------------------------------------
752
753			?>
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26