1 | /* |
2 | * This Source Code Form is subject to the terms of the Mozilla Public |
3 | * License, v. 2.0. If a copy of the MPL was not distributed with this |
4 | * file, You can obtain one at http://mozilla.org/MPL/2.0/. |
5 | * |
6 | * Copyright 1997 - July 2008 CWI, August 2008 - 2019 MonetDB B.V. |
7 | */ |
8 | |
9 | /* (c) M.L. Kersten |
10 | * The order index interface routines are defined here. |
11 | */ |
12 | #include "monetdb_config.h" |
13 | #include "mal_backend.h" |
14 | #include "sql_scenario.h" |
15 | #include "sql_result.h" |
16 | #include "sql_gencode.h" |
17 | #include "sql_optimizer.h" |
18 | #include "sql_env.h" |
19 | #include "sql_mvc.h" |
20 | #include "sql_orderidx.h" |
21 | #include "orderidx.h" |
22 | #include "sql_scenario.h" |
23 | |
24 | str |
25 | sql_createorderindex(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci) |
26 | { |
27 | mvc *m = NULL; |
28 | str msg = getSQLContext(cntxt, mb, &m, NULL); |
29 | str sch,tbl,col; |
30 | sql_schema *s; |
31 | sql_table *t; |
32 | sql_column *c; |
33 | BAT *b; |
34 | |
35 | if (msg != MAL_SUCCEED || (msg = checkSQLContext(cntxt)) != NULL) |
36 | return msg; |
37 | |
38 | sch = *getArgReference_str(stk, pci, 1); |
39 | tbl = *getArgReference_str(stk, pci, 2); |
40 | col = *getArgReference_str(stk, pci, 3); |
41 | |
42 | #ifdef DEBUG_SQL_ORDERIDX |
43 | fprintf(stderr, "#orderindex layout %s.%s.%s \n" , sch, tbl, col); |
44 | #endif |
45 | s = mvc_bind_schema(m, sch); |
46 | if (s == NULL) |
47 | throw(SQL, "sql.createorderindex" , SQLSTATE(42000) "Unknown schema %s" , sch); |
48 | t = mvc_bind_table(m, s, tbl); |
49 | if (t == NULL || !isTable(t)) |
50 | throw(SQL, "sql.createorderindex" , SQLSTATE(42000) "Unknown table %s.%s" , |
51 | sch, tbl); |
52 | c = mvc_bind_column(m, t, col); |
53 | if (c == NULL) |
54 | throw(SQL, "sql.createorderindex" , SQLSTATE(42000) "Unknown column %s.%s.%s" , |
55 | sch, tbl, col); |
56 | b = store_funcs.bind_col(m->session->tr, c, 0); |
57 | if (b == 0) |
58 | throw(SQL,"sql.createorderindex" , SQLSTATE(HY005) "Column can not be accessed" ); |
59 | /* create the ordered index on the column */ |
60 | msg = OIDXcreateImplementation(cntxt, newBatType(b->ttype), b, -1); |
61 | BBPunfix(b->batCacheid); |
62 | return msg; |
63 | } |
64 | |
65 | str |
66 | sql_droporderindex(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci) |
67 | { |
68 | mvc *m = NULL; |
69 | str msg = getSQLContext(cntxt, mb, &m, NULL); |
70 | str sch,tbl,col; |
71 | sql_schema *s; |
72 | sql_table *t; |
73 | sql_column *c; |
74 | BAT *b; |
75 | |
76 | if (msg != MAL_SUCCEED || (msg = checkSQLContext(cntxt)) != NULL) |
77 | return msg; |
78 | |
79 | sch = *getArgReference_str(stk, pci, 1); |
80 | tbl = *getArgReference_str(stk, pci, 2); |
81 | col = *getArgReference_str(stk, pci, 3); |
82 | |
83 | #ifdef DEBUG_SQL_ORDERIDX |
84 | fprintf(stderr, "#orderindex layout %s.%s.%s \n" , sch, tbl, col); |
85 | #endif |
86 | s = mvc_bind_schema(m, sch); |
87 | if (s == NULL) |
88 | throw(SQL, "sql.droporderindex" , SQLSTATE(3FOOO) "Unknown schema %s" , sch); |
89 | t = mvc_bind_table(m, s, tbl); |
90 | if (t == NULL || !isTable(t)) |
91 | throw(SQL, "sql.droporderindex" , SQLSTATE(42S02) "Unknown table %s.%s" , sch, tbl); |
92 | c = mvc_bind_column(m, t, col); |
93 | if (c == NULL) |
94 | throw(SQL, "sql.droporderindex" , SQLSTATE(38000) "Unknown column %s.%s.%s" , sch, tbl, col); |
95 | b = store_funcs.bind_col(m->session->tr, c, 0); |
96 | if (b == 0) |
97 | throw(SQL,"sql.droporderindex" , SQLSTATE(38000) "Column can not be accessed" ); |
98 | msg = OIDXdropImplementation(cntxt, b); |
99 | BBPunfix(b->batCacheid); |
100 | return MAL_SUCCEED; |
101 | } |
102 | |
103 | |