Mercurial > forge

annotate main/database/src/converters_arr_comp.cc @ 11657:465192f682f0 octave-forge

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Pass connection information to converters.
author i7tiol
date Sat, 27 Apr 2013 09:35:39 +0000
parents b257244ad466
children ee2b22964070
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
1 /*
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
2
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
3 Copyright (C) 2012, 2013 Olaf Till <i7tiol@t-online.de>
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
4
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
5 This program is free software; you can redistribute it and/or modify
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
6 it under the terms of the GNU General Public License as published by
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
7 the Free Software Foundation; either version 3 of the License, or
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
8 (at your option) any later version.
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
9
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
10 This program is distributed in the hope that it will be useful,
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
13 GNU General Public License for more details.
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
14
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
15 You should have received a copy of the GNU General Public License
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
16 along with this program; If not, see <http://www.gnu.org/licenses/>.
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
17
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
18 */
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
19
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
20 #include <octave/oct.h>
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
21 #include <octave/ov-struct.h>
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
22 #include <octave/Cell.h>
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
23 #include <octave/lo-ieee.h>
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
24
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
25 #include <stdint.h>
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
26
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
27 #include "command.h"
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
28
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
29 octave_idx_type command::count_row_major_order (dim_vector &dv,
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
30 count_state &state, bool init)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
31 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
32 if (init)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
33 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
34 state.nd = dv.length ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
35
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
36 state.cur.resize (state.nd);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
37
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
38 state.pd.resize (state.nd);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
39
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
40 // cannot be done with resize in multiple initializations
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
41 // (resizing to n<2 not possible) and there is no fill() method
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
42 for (octave_idx_type i = 0; i < state.nd; i++)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
43 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
44 state.cur(i) = 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
45 state.pd(i) = 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
46 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
47
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
48 for (octave_idx_type i = 0; i < state.nd - 1; i++)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
49 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
50 state.pd(i + 1) = state.pd(i) * dv(i);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
51 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
52
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
53 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
54 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
55 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
56 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
57 octave_idx_type nd = state.nd;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
58
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
59 if (nd > 0)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
60 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
61 octave_idx_type ret = 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
62
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
63 state.cur(nd - 1)++;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
64
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
65 for (octave_idx_type i = nd - 1; i > 0; i--)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
66 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
67 if (state.cur(i) == dv(i))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
68 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
69 state.cur(i) = 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
70 state.cur(i - 1)++;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
71 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
72
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
73 ret += state.cur(i) * state.pd(i);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
74 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
75
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
76 if (state.cur(0) == dv(0))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
77 ret = -1; // signals overflow
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
78 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
79 ret += state.cur(0) * state.pd(0);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
80
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
81 return ret;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
82 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
83 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
84 return -1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
85 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
86 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
87
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
88 int command::from_octave_bin_array (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
89 const octave_value &oct_arr,
11407
f4098c7d5b35 Wrong implementation of copy-in from argument.
i7tiol
parents: 11394
diff changeset
90 oct_pq_dynvec_t &val, oct_pq_conv_t *conv)
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
91 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
92 octave_scalar_map m = oct_arr.scalar_map_value ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
93 if (error_state)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
94 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
95 error ("%s: Postgresql array parameter no Octave structure",
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
96 caller.c_str ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
97 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
98 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
99
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
100 if (! m.isfield ("ndims") || ! m.isfield ("data"))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
101 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
102 error ("%s: field 'ndims' or 'data' missing in parameter for Postgresql array", caller.c_str ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
103 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
104 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
105
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
106 octave_idx_type nd_pq = m.contents ("ndims").int_value ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
107 Cell arr = m.contents ("data").cell_value ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
108 if (error_state || nd_pq < 0)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
109 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
110 error ("%s: 'ndims' and 'data' could not be converted to non-negative integer and cell-array in parameter for Postgresql array", caller.c_str ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
111 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
112 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
113
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
114 RowVector lb;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
115
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
116 // Are lbounds given?
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
117 if (m.isfield ("lbounds"))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
118 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
119 lb = m.contents ("lbounds").row_vector_value ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
120 if (error_state)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
121 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
122 error ("%s: could not convert given enumeration bases for array to row vector", caller.c_str ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
123 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
124 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
125 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
126
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
127 octave_idx_type nl = arr.numel ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
128
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
129 // dimensions of Octaves representation of postgresql array
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
130 dim_vector d = arr.dims ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
131 d.chop_trailing_singletons ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
132 int nd_oct = d.length ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
133 if (nd_oct == 2 && d(1) == 1)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
134 nd_oct = 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
135
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
136 // check dimensions
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
137 if (nd_oct > nd_pq)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
138 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
139 error ("given representation of postgresql array has more dimensions than specified");
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
140 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
141 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
142
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
143 // check lbounds
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
144 if (nd_pq > 0 && lb.is_empty ())
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
145 lb.resize (nd_pq, 1); // fill with 1
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
146 else if (lb.length () != nd_pq)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
147 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
148 error ("number of specified enumeration bases for array does not match specified number of dimensions");
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
149 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
150 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
151
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
152 // ndim
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
153 OCT_PQ_PUT(val, int32_t, htobe32 ((int32_t) nd_pq))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
154 // always make a NULL-bitmap, we don't scan for NULLs to see if it
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
155 // is really necessary
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
156 OCT_PQ_PUT(val, int32_t, htobe32 ((int32_t) 1))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
157 // element OID
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
158 OCT_PQ_PUT(val, uint32_t, htobe32 ((uint32_t) conv->oid))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
159 // dims, lbounds
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
160 for (int i = 0; i < nd_pq; i++)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
161 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
162 OCT_PQ_PUT(val, int32_t, htobe32 ((int32_t) (i < nd_oct ? d(i) : 1)))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
163 OCT_PQ_PUT(val, int32_t, htobe32 ((int32_t) lb(i)))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
164 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
165 // elements
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
166 count_state state;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
167 count_row_major_order (d, state, true); // initialize counter
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
168 for (int i = 0, ti = 0; ti < nl;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
169 ti++, i = count_row_major_order (d, state, false))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
170 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
171 if (arr(i).is_real_scalar () && arr(i).isna ().bool_value ())
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
172 // a length value (uint32_t) would not have the 6 highest bits
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
173 // set (while this has all bits set)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
174 { OCT_PQ_PUT(val, int32_t, htobe32 ((int32_t) -1)) }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
175 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
176 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
177 OCT_PQ_SET_UINT32_PLACEHOLDER(val, temp_pos)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
178
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
179 if (conv->is_composite)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
180 {
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
181 if (from_octave_bin_composite (conn, arr(i), val, conv))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
182 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
183 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
184 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
185 {
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
186 if (conv->from_octave_bin (conn, arr(i), val))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
187 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
188 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
189
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
190 OCT_PQ_FILL_UINT32_PLACEHOLDER(val, temp_pos)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
191 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
192 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
193
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
194 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
195 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
196
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
197 int command::from_octave_bin_composite (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
198 const octave_value &oct_comp,
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
199 oct_pq_dynvec_t &val,
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
200 oct_pq_conv_t *conv)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
201 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
202 Cell rec (oct_comp.cell_value ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
203 if (error_state)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
204 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
205 error ("%s: Octaves representation of a composite type could not be converted to cell-array", caller.c_str ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
206 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
207 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
208
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
209 octave_idx_type nl = rec.numel ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
210
11645
bd5a8f1bdfb8 Clean out harmless warnings and one unnecessarily returned column.
i7tiol
parents: 11644
diff changeset
211 if (size_t (nl) != conv->el_oids.size ())
11474
4fd39d36eff5 Retrieve element information of composite types already at connection time. Exclude negative element numbers (system columns) of composite types corresponding to tables.
i7tiol
parents: 11407
diff changeset
212 {
4fd39d36eff5 Retrieve element information of composite types already at connection time. Exclude negative element numbers (system columns) of composite types corresponding to tables.
i7tiol
parents: 11407
diff changeset
213 error ("%s: Octaves representation of a composite type has incorrect number of elements (%i, should have %i)",
4fd39d36eff5 Retrieve element information of composite types already at connection time. Exclude negative element numbers (system columns) of composite types corresponding to tables.
i7tiol
parents: 11407
diff changeset
214 caller.c_str (), nl, conv->el_oids.size ());
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
215
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
216 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
217 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
218
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
219 // ncols
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
220 OCT_PQ_PUT(val, int32_t, htobe32 ((int32_t) nl))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
221 // elements
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
222 for (int i = 0; i < nl; i++)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
223 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
224 // element OID
11474
4fd39d36eff5 Retrieve element information of composite types already at connection time. Exclude negative element numbers (system columns) of composite types corresponding to tables.
i7tiol
parents: 11407
diff changeset
225 OCT_PQ_PUT(val, uint32_t, htobe32 ((uint32_t) conv->el_oids[i]))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
226 if (rec(i).is_real_scalar () && rec(i).isna ().bool_value ())
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
227 // a length value (uint32_t) would not have the 6 highest bits
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
228 // set (while this has all bits set)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
229 { OCT_PQ_PUT(val, int32_t, htobe32 ((int32_t) -1)) }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
230 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
231 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
232 OCT_PQ_SET_UINT32_PLACEHOLDER(val, temp_pos)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
233
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
234 oct_pq_conv_t *el_conv;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
235 oct_type_t oct_type;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
236
11480
d14a23884d9c Cache map lookups of converters for composite type elements.
i7tiol
parents: 11474
diff changeset
237 if (! (el_conv = pgtype_from_spec (conv->el_oids[i],
d14a23884d9c Cache map lookups of converters for composite type elements.
i7tiol
parents: 11474
diff changeset
238 conv->conv_cache[i],
d14a23884d9c Cache map lookups of converters for composite type elements.
i7tiol
parents: 11474
diff changeset
239 oct_type)))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
240 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
241
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
242 switch (oct_type)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
243 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
244 case simple:
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
245 if (el_conv->from_octave_bin (conn, rec(i), val))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
246 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
247 break;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
248
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
249 case array:
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
250 if (from_octave_bin_array (conn, rec(i), val, el_conv))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
251 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
252 break;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
253
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
254 case composite:
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
255 if (from_octave_bin_composite (conn, rec(i), val, el_conv))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
256 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
257 break;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
258
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
259 default:
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
260 // should not get here
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
261 error ("%s: internal error, undefined type identifier",
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
262 caller.c_str ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
263 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
264 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
265
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
266 OCT_PQ_FILL_UINT32_PLACEHOLDER(val, temp_pos)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
267 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
268 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
269
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
270 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
271 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
272
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
273 int command::from_octave_str_array (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
274 const octave_value &oct_arr,
11407
f4098c7d5b35 Wrong implementation of copy-in from argument.
i7tiol
parents: 11394
diff changeset
275 oct_pq_dynvec_t &val, octave_value &type)
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
276 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
277 // not implemented
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
278 error ("not implemented");
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
279 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
280
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
281 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
282 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
283
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
284 int command::from_octave_str_composite (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
285 const octave_value &oct_comp,
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
286 oct_pq_dynvec_t &val,
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
287 octave_value &type)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
288 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
289 // not implemented
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
290 error ("not implemented");
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
291 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
292
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
293 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
294 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
295
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
296 int command::to_octave_bin_array (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
297 char *v, octave_value &ov, int nb,
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
298 oct_pq_conv_t *conv)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
299 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
300 char *p = v;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
301
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
302 // ndim
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
303 OCT_PQ_DECL_GET_INT32(ndim, p, int32_t)
11645
bd5a8f1bdfb8 Clean out harmless warnings and one unnecessarily returned column.
i7tiol
parents: 11644
diff changeset
304 // Has NULL bitmap. Since this information is not used, comment it
bd5a8f1bdfb8 Clean out harmless warnings and one unnecessarily returned column.
i7tiol
parents: 11644
diff changeset
305 // out to avoid a warning and increase the pointer manually.
bd5a8f1bdfb8 Clean out harmless warnings and one unnecessarily returned column.
i7tiol
parents: 11644
diff changeset
306 //
bd5a8f1bdfb8 Clean out harmless warnings and one unnecessarily returned column.
i7tiol
parents: 11644
diff changeset
307 // OCT_PQ_DECL_GET_INT32(hasnull, p, int32_t)
bd5a8f1bdfb8 Clean out harmless warnings and one unnecessarily returned column.
i7tiol
parents: 11644
diff changeset
308 p += 4;
bd5a8f1bdfb8 Clean out harmless warnings and one unnecessarily returned column.
i7tiol
parents: 11644
diff changeset
309 //
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
310 // element OID
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
311 OCT_PQ_DECL_GET_INT32(oid, p, uint32_t)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
312
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
313 // check element OID
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
314 if (oid != conv->oid)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
315 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
316 error ("%s: element oid %i sent by server does not match element oid %i expected for array with oid %i",
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
317 caller.c_str (), oid, conv->oid, conv->aoid);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
318 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
319 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
320
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
321 // dims, lbounds
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
322 dim_vector dv;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
323 dv.resize (ndim, 0); // ndim < 2 is treated as ndim == 2
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
324 if (ndim == 1)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
325 dv(1) = 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
326
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
327 RowVector lbounds (ndim);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
328
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
329 for (int i = 0; i < ndim; i++)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
330 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
331 OCT_PQ_GET_INT32(dv(i), p, int32_t)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
332 OCT_PQ_GET_INT32(lbounds(i), p, int32_t)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
333 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
334 //
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
335
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
336 // elements
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
337 octave_idx_type nl = dv.numel ();
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
338 Cell c (dv);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
339 count_state state;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
340 count_row_major_order (dv, state, true); // initialize counter
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
341 for (int i = 0, ti = 0; ti < nl;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
342 ti++, i = count_row_major_order (dv, state, false))
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
343 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
344 OCT_PQ_DECL_GET_INT32(null_id, p, int32_t)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
345 if (null_id == -1)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
346 // NULL
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
347 c(i) = octave_value (octave_NA);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
348 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
349 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
350 uint32_t nb_el = uint32_t (null_id);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
351
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
352 octave_value ov_el;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
353
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
354 if (conv->is_composite)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
355 {
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
356 if (to_octave_bin_composite (conn, p, ov_el, nb_el, conv))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
357 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
358 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
359 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
360 {
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
361 if (conv->to_octave_bin (conn, p, ov_el, nb_el))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
362 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
363 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
364
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
365 p += nb_el;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
366
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
367 c(i) = ov_el;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
368 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
369 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
370
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
371 octave_scalar_map m;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
372 m.assign ("data", octave_value (c));
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
373 m.assign ("ndims", octave_value (ndim));
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
374 m.assign ("lbounds", octave_value (lbounds));
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
375
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
376 ov = octave_value (m);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
377
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
378 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
379 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
380
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
381 int command::to_octave_bin_composite (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
382 char *v, octave_value &ov, int nb,
11480
d14a23884d9c Cache map lookups of converters for composite type elements.
i7tiol
parents: 11474
diff changeset
383 oct_pq_conv_t *conv)
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
384 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
385 char *p = v;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
386
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
387 // ncols
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
388 OCT_PQ_DECL_GET_INT32(nl, p, int32_t)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
389
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
390 // elements
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
391 Cell c (nl, 1);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
392 for (int i = 0; i < nl; i++)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
393 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
394 // element OID
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
395 OCT_PQ_DECL_GET_INT32(oid, p, uint32_t)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
396
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
397 OCT_PQ_DECL_GET_INT32(null_id, p, int32_t)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
398
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
399 if (null_id == -1)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
400 // NULL
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
401 c(i) = octave_value (octave_NA);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
402 else
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
403 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
404 uint32_t nb_el = uint32_t (null_id);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
405
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
406 oct_pq_conv_t *el_conv;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
407 oct_type_t oct_type;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
408
11480
d14a23884d9c Cache map lookups of converters for composite type elements.
i7tiol
parents: 11474
diff changeset
409 if (! (el_conv = pgtype_from_spec (oid, conv->conv_cache[i],
d14a23884d9c Cache map lookups of converters for composite type elements.
i7tiol
parents: 11474
diff changeset
410 oct_type)))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
411 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
412
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
413 octave_value el;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
414 switch (oct_type)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
415 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
416 case simple:
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
417 if (el_conv->to_octave_bin (conn, p, el, nb_el))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
418 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
419 break;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
420
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
421 case array:
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
422 if (to_octave_bin_array (conn, p, el, nb_el, el_conv))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
423 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
424 break;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
425
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
426 case composite:
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
427 if (to_octave_bin_composite (conn, p, el, nb_el, el_conv))
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
428 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
429 break;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
430
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
431 default:
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
432 // should not get here
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
433 error ("%s: internal error, undefined type identifier",
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
434 caller.c_str ());
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
435 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
436 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
437
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
438 p += nb_el;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
439
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
440 c(i) = el;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
441 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
442 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
443
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
444 ov = octave_value (c);
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
445
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
446 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
447 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
448
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
449
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
450 int command::to_octave_str_array (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
451 char *v, octave_value &ov, int nb,
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
452 oct_pq_conv_t *conv)
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
453 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
454 // not implemented
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
455 error ("not implemented");
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
456 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
457
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
458 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
459 }
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
460
11657
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
461 int command::to_octave_str_composite (const octave_pq_connection &conn,
465192f682f0 Pass connection information to converters.
i7tiol
parents: 11646
diff changeset
462 char *v, octave_value &ov, int nb,
11480
d14a23884d9c Cache map lookups of converters for composite type elements.
i7tiol
parents: 11474
diff changeset
463 oct_pq_conv_t *conv)
11394
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
464 {
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
465 // not implemented
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
466 error ("not implemented");
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
467 return 1;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
468
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
469 return 0;
9aee227e296c Populated new database package with initial postgresql interface.
i7tiol
parents:
diff changeset
470 }