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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
/*
* $Id$
*
* UNIXODBC module
*
* Copyright (C) 2005-2006 Marco Lorrai
* Copyright (C) 2008 1&1 Internet AG
*
* 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*
*
* History:
* --------
* 2005-12-01 initial commit (chgen)
*/
#include "../../dprint.h"
#include "../../lib/kcore/strcommon.h"
#include "../../lib/srdb1/db_ut.h"
#include "db_unixodbc.h"
#include "val.h"
#include "connection.h"
/*
* Used when converting the query to a result
*/
int db_unixodbc_str2val(const db_type_t _t, db_val_t* _v, const char* _s, const int _l,
const unsigned int _cpy)
{
/* db_unixodbc uses the NULL string for NULL SQL values */
if (_v && _s && !strcmp(_s, "NULL")) {
LM_DBG("converting NULL value");
static str dummy_string = {"", 0};
memset(_v, 0, sizeof(db_val_t));
/* Initialize the string pointers to a dummy empty
* string so that we do not crash when the NULL flag
* is set but the module does not check it properly
*/
VAL_STRING(_v) = dummy_string.s;
VAL_STR(_v) = dummy_string;
VAL_BLOB(_v) = dummy_string;
VAL_TYPE(_v) = _t;
VAL_NULL(_v) = 1;
return 0;
} else {
return db_str2val(_t, _v, _s, _l, _cpy);
}
}
/*
* Used when converting a result from the query
*/
int db_unixodbc_val2str(const db1_con_t* _c, const db_val_t* _v, char* _s, int* _len)
{
int l, tmp;
char* old_s;
/* db_unixodbc uses a custom escape function */
tmp = db_val2str(_c, _v, _s, _len);
if (tmp < 1)
return tmp;
switch(VAL_TYPE(_v))
{
case DB1_STRING:
l = strlen(VAL_STRING(_v));
if (*_len < (l * 2 + 3))
{
LM_ERR("destination buffer too short\n");
return -6;
}
else
{
old_s = _s;
*_s++ = '\'';
if(use_escape_common)
{
_s += escape_common(_s, (char*)VAL_STRING(_v), l);
} else {
memcpy(_s, VAL_STRING(_v), l);
_s += l;
}
*_s++ = '\'';
*_s = '\0'; /* FIXME */
*_len = _s - old_s;
return 0;
}
break;
case DB1_STR:
l = VAL_STR(_v).len;
if (*_len < (l * 2 + 3))
{
LM_ERR("destination buffer too short\n");
return -7;
}
else
{
old_s = _s;
*_s++ = '\'';
if(use_escape_common)
{
_s += escape_common(_s, VAL_STR(_v).s, l);
} else {
memcpy(_s, VAL_STR(_v).s, l);
_s += l;
}
*_s++ = '\'';
*_s = '\0'; /* FIXME */
*_len = _s - old_s;
return 0;
}
break;
case DB1_BLOB:
l = VAL_BLOB(_v).len;
if (*_len < (l * 2 + 3))
{
LM_ERR("destination buffer too short\n");
return -9;
}
else
{
old_s = _s;
*_s++ = '\'';
if(use_escape_common)
{
_s += escape_common(_s, VAL_BLOB(_v).s, l);
} else {
memcpy(_s, VAL_BLOB(_v).s, l);
_s += l;
}
*_s++ = '\'';
*_s = '\0'; /* FIXME */
*_len = _s - old_s;
return 0;
}
break;
default:
LM_DBG("unknown data type\n");
return -10;
}
}
|
