|
@@ -1,273 +0,0 @@
|
|
|
-/*
|
|
|
- * $Id$
|
|
|
- *
|
|
|
- * Copyright (C) 2001-2003 FhG Fokus
|
|
|
- *
|
|
|
- * This file is part of Kamailio, a free SIP server.
|
|
|
- *
|
|
|
- * Kamailio is free software; you can redistribute it and/or modify
|
|
|
- * it under the terms of the GNU General Public License as published by
|
|
|
- * the Free Software Foundation; either version 2 of the License, or
|
|
|
- * (at your option) any later version
|
|
|
- *
|
|
|
- * Kamailio is distributed in the hope that it will be useful,
|
|
|
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
- * GNU General Public License for more details.
|
|
|
- *
|
|
|
- * You should have received a copy of the GNU General Public License
|
|
|
- * along with this program; if not, write to the Free Software
|
|
|
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
|
- */
|
|
|
-
|
|
|
-
|
|
|
-#include "../../sr_module.h"
|
|
|
-#include <stdio.h>
|
|
|
-#include "../../db/db.h"
|
|
|
-
|
|
|
-
|
|
|
-#define DB_URL "mysql://root@localhost/ser"
|
|
|
-#define DB_TABLE "location"
|
|
|
-
|
|
|
-#define TRUE 1
|
|
|
-#define FALSE 0
|
|
|
-
|
|
|
-
|
|
|
-/*
|
|
|
- * Database module client example
|
|
|
- */
|
|
|
-
|
|
|
-
|
|
|
-static struct module_exports dbex_exports= {
|
|
|
- "DBExample",
|
|
|
- (char*[]) {
|
|
|
- },
|
|
|
- (cmd_function[]) {
|
|
|
- },
|
|
|
- (int[]) {
|
|
|
- },
|
|
|
- (fixup_function[]) {
|
|
|
- },
|
|
|
- 0, /* number of functions*/
|
|
|
- NULL, /* Module parameter names */
|
|
|
- NULL, /* Module parameter types */
|
|
|
- NULL, /* Module parameter variable pointers */
|
|
|
- 0, /* Number of module parameters */
|
|
|
- 0, /* response function*/
|
|
|
- 0 /* destroy function */
|
|
|
-};
|
|
|
-
|
|
|
-
|
|
|
-static int print_res(db_res_t* _r)
|
|
|
-{
|
|
|
- int i, j;
|
|
|
-
|
|
|
- for(i = 0; i < RES_COL_N(_r); i++) {
|
|
|
- printf("%s ", RES_NAMES(_r)[i]);
|
|
|
- }
|
|
|
- printf("\n");
|
|
|
-
|
|
|
- for(i = 0; i < RES_ROW_N(_r); i++) {
|
|
|
- for(j = 0; j < RES_COL_N(_r); j++) {
|
|
|
- if (RES_ROWS(_r)[i].values[j].nul == TRUE) {
|
|
|
- printf("NULL ");
|
|
|
- continue;
|
|
|
- }
|
|
|
- switch(RES_ROWS(_r)[i].values[j].type) {
|
|
|
- case DB_INT:
|
|
|
- printf("%d ", RES_ROWS(_r)[i].values[j].val.int_val);
|
|
|
- break;
|
|
|
- case DB_DOUBLE:
|
|
|
- printf("%f ", RES_ROWS(_r)[i].values[j].val.double_val);
|
|
|
- break;
|
|
|
- case DB_DATETIME:
|
|
|
- printf("%s ", ctime(&(RES_ROWS(_r)[i].values[j].val.time_val)));
|
|
|
- break;
|
|
|
- case DB_STRING:
|
|
|
- printf("%s ", RES_ROWS(_r)[i].values[j].val.string_val);
|
|
|
- break;
|
|
|
- case DB_STR:
|
|
|
- printf("%.*s ",
|
|
|
- RES_ROWS(_r)[i].values[j].val.str_val.len,
|
|
|
- RES_ROWS(_r)[i].values[j].val.str_val.s);
|
|
|
- break;
|
|
|
-
|
|
|
- case DB_BLOB:
|
|
|
- printf("%.*s ",
|
|
|
- RES_ROWS(_r)[i].values[j].val.blob_val.len,
|
|
|
- RES_ROWS(_r)[i].values[j].val.blob_val.s);
|
|
|
- break;
|
|
|
-
|
|
|
- case DB_BITMAP:
|
|
|
- printf("%d ", RES_ROWS(_r)[i].values[j].val.bitmap_val);
|
|
|
- break;
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- printf("\n");
|
|
|
- }
|
|
|
-
|
|
|
- return TRUE;
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-struct module_exports* mod_register()
|
|
|
-{
|
|
|
- /*
|
|
|
- * Column names of table location
|
|
|
- */
|
|
|
- db_key_t keys1[] = {"username", "contact", "q", "expire", "opaque", "flags" };
|
|
|
- db_key_t keys2[] = {"username", "q"};
|
|
|
- db_key_t keys3[] = {"username", "contact"};
|
|
|
- db_key_t keys4[] = {"contact", "q"};
|
|
|
-
|
|
|
- db_val_t vals1[] = {
|
|
|
- { DB_STRING , 0, { .string_val = "[email protected]" } },
|
|
|
- { DB_STR , 0, { .str_val = { "[email protected]", 18 } } },
|
|
|
- { DB_DOUBLE , 0, { .double_val = 1.2 } },
|
|
|
- { DB_DATETIME, 0, { .time_val = 439826493 } },
|
|
|
- { DB_BLOB , 0, { .blob_val = { "hdslgkhas\0glksf", 17 } } },
|
|
|
- { DB_BITMAP , 0, { .bitmap_val = FLAG_NAT | FLAG_INVITE } }
|
|
|
- };
|
|
|
-
|
|
|
- db_val_t vals2[] = {
|
|
|
- { DB_STRING , 0, { .string_val = "[email protected]" } },
|
|
|
- { DB_STR , 0, { .str_val = { "[email protected]", 18 } } },
|
|
|
- { DB_DOUBLE , 0, { .double_val = 1.3 } },
|
|
|
- { DB_DATETIME, 0, { .time_val = 12345 } },
|
|
|
- { DB_BLOB , 0, { .blob_val = { "\0a\0balkdfj", 10 } } },
|
|
|
- { DB_BITMAP , 0, { .bitmap_val = FLAG_NAT, FLAG_NOT_INVITE } }
|
|
|
- };
|
|
|
-
|
|
|
- db_val_t vals3[] = {
|
|
|
- { DB_STRING , 0, { .string_val = "[email protected]" } },
|
|
|
- { DB_STR , 0, { .str_val = { "[email protected]", 18 } } },
|
|
|
- { DB_DOUBLE , 0, { .double_val = 1.5 } },
|
|
|
- { DB_DATETIME, 0, { .time_val = 123456 } },
|
|
|
- { DB_BLOB , 0, { .blob_val = { "halgkasdg\'", 10 } } },
|
|
|
- { DB_BITMAP , 0, { .blob_val = FLAG_NAT } }
|
|
|
- };
|
|
|
-
|
|
|
- db_val_t vals4[] = {
|
|
|
- { DB_STRING, 0, { .string_val = "[email protected]" } },
|
|
|
- { DB_DOUBLE, 0, { .double_val = 1.30 } }
|
|
|
- };
|
|
|
-
|
|
|
- db_val_t vals5[] = {
|
|
|
- { DB_STRING, 0, { .string_val = "[email protected]" } },
|
|
|
- { DB_STRING, 0, { .string_val = "[email protected]" } }
|
|
|
- };
|
|
|
-
|
|
|
- db_val_t vals6[] = {
|
|
|
- { DB_STRING, 0, { .string_val = "[email protected]" } },
|
|
|
- { DB_DOUBLE, 0, { .double_val = 2.5 } }
|
|
|
- };
|
|
|
-
|
|
|
- db_con_t* h;
|
|
|
- db_res_t* res = NULL;
|
|
|
-
|
|
|
- fprintf(stderr, "DBExample - registering...\n");
|
|
|
-
|
|
|
- /* The first call must be bind_dbmod
|
|
|
- * This call will search for functions
|
|
|
- * exported by a database module
|
|
|
- */
|
|
|
- if (bind_dbmod()) {
|
|
|
- fprintf(stderr, "Error while binding database module, did you forget to load a database module ?\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- /*
|
|
|
- * Create a database connection
|
|
|
- * DB_URL is database URL of form
|
|
|
- * mysql://user:password@host:port/database
|
|
|
- * The function returns handle, that
|
|
|
- * represents a database connection
|
|
|
- */
|
|
|
- h = db_init(DB_URL);
|
|
|
- if (!h) {
|
|
|
- fprintf(stderr, "Error while initializing database connection\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- /*
|
|
|
- * Specify a table name, that will
|
|
|
- * be used for manipulations
|
|
|
- */
|
|
|
- if (db_use_table(h, DB_TABLE) < 0) {
|
|
|
- fprintf(stderr, "Error while calling db_use_table\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- /* If you do not specify any keys and values to be
|
|
|
- * matched, all rows will be deleted
|
|
|
- */
|
|
|
- if (db_delete(h, NULL, NULL, NULL, 0) < 0) {
|
|
|
- fprintf(stderr, "Error while flushing table\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- if (db_insert(h, keys1, vals1, 6) < 0) {
|
|
|
- fprintf(stderr, "Error while inserting line 1\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- if (db_insert(h, keys1, vals2, 6) < 0) {
|
|
|
- fprintf(stderr, "Error while inserting line 2\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- if (db_insert(h, keys1, vals3, 6) < 0) {
|
|
|
- fprintf(stderr, "Error while inserting line 3\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- /*
|
|
|
- * Let's delete middle line with
|
|
|
- * user = [email protected] and q = 1.3
|
|
|
- */
|
|
|
- if (db_delete(h, keys2, NULL, vals4, 2) < 0) {
|
|
|
- fprintf(stderr, "Error while deleting line\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- /*
|
|
|
- * Modify last line
|
|
|
- */
|
|
|
- if (db_update(h, keys3, NULL, vals5, keys4, vals6, 2, 2) < 0) {
|
|
|
- fprintf(stderr, "Error while modifying table\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- /*
|
|
|
- * Last but not least, dump the result of db_query
|
|
|
- */
|
|
|
-
|
|
|
- if (db_query(h, NULL, NULL, NULL, NULL, 0, 0, NULL, &res) < 0) {
|
|
|
- fprintf(stderr, "Error while querying table\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- print_res(res);
|
|
|
-
|
|
|
- /*
|
|
|
- * Free the result because we don't need it
|
|
|
- * anymore
|
|
|
- */
|
|
|
- if (db_free_result(h, res) < 0) {
|
|
|
- fprintf(stderr, "Error while freeing result of query\n");
|
|
|
- return &dbex_exports;
|
|
|
- }
|
|
|
-
|
|
|
- /*
|
|
|
- * Close existing database connection
|
|
|
- * and free previously allocated
|
|
|
- * memory
|
|
|
- */
|
|
|
- db_close(h);
|
|
|
- return &dbex_exports;
|
|
|
-}
|