Mon, 31 Jan 2022 17:18:12 +0100
add basic postgresql vfs directory functions
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
1 | /* |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
2 | * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
3 | * |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
4 | * Copyright 2022 Olaf Wintermann. All rights reserved. |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
5 | * |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
6 | * Redistribution and use in source and binary forms, with or without |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
7 | * modification, are permitted provided that the following conditions are met: |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
8 | * |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
9 | * 1. Redistributions of source code must retain the above copyright |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
10 | * notice, this list of conditions and the following disclaimer. |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
11 | * |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
12 | * 2. Redistributions in binary form must reproduce the above copyright |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
13 | * notice, this list of conditions and the following disclaimer in the |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
14 | * documentation and/or other materials provided with the distribution. |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
15 | * |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
16 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
17 | * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
18 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
19 | * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
20 | * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
21 | * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
22 | * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
23 | * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
24 | * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
25 | * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
26 | * POSSIBILITY OF SUCH DAMAGE. |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
27 | */ |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
28 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
29 | #include "vfs.h" |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
30 | |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
31 | #include <inttypes.h> |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
32 | |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
33 | #include "../../util/util.h" |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
34 | |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
35 | static VFS pg_vfs_class = { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
36 | pg_vfs_open, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
37 | pg_vfs_stat, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
38 | pg_vfs_fstat, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
39 | pg_vfs_opendir, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
40 | pg_vfs_fdopendir, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
41 | pg_vfs_mkdir, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
42 | pg_vfs_unlink, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
43 | pg_vfs_rmdir |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
44 | }; |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
45 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
46 | static VFS_IO pg_vfs_io_class = { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
47 | pg_vfs_io_read, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
48 | pg_vfs_io_write, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
49 | pg_vfs_io_pread, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
50 | pg_vfs_io_pwrite, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
51 | pg_vfs_io_seek, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
52 | pg_vfs_io_close, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
53 | NULL, // no pg aio implementation yet |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
54 | NULL |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
55 | }; |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
56 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
57 | static VFS_DIRIO pg_vfs_dirio_class = { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
58 | pg_vfs_dirio_readdir, |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
59 | pg_vfs_dirio_close |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
60 | }; |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
61 | |
276
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
62 | |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
63 | /* |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
64 | * SQL Queries |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
65 | */ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
66 | |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
67 | // Resolves a path into resource_id and parent_id |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
68 | // params: $1: path string |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
69 | static const char *sql_resolve_path = |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
70 | "with recursive resolvepath as (\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
71 | select\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
72 | resource_id,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
73 | parent_id,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
74 | iscollection,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
75 | regexp_split_to_array($1, '/') as pathelm,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
76 | '' as fullpath,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
77 | 1 as pathdepth\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
78 | from Resource\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
79 | where parent_id is null\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
80 | union\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
81 | select\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
82 | r.resource_id,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
83 | r.parent_id,\n\ |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
84 | r.iscollection,\n\ |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
85 | p.pathelm,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
86 | p.fullpath || '/' || r.nodename,\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
87 | p.pathdepth + 1\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
88 | from Resource r\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
89 | inner join resolvepath p on r.parent_id = p.resource_id\n\ |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
90 | where p.pathelm[p.pathdepth+1] = r.nodename\n\ |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
91 | )\n\ |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
92 | select resource_id, parent_id, fullpath, iscollection from resolvepath\n\ |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
93 | where fullpath = $1 ;"; |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
94 | |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
95 | // Same as sql_resolve_path, but it returns the root collection |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
96 | // params: $1: path string (should be '/') |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
97 | static const char *sql_get_root = "select resource_id, parent_id, $1 as fullpath, true as iscollection from Resource where parent_id is null;"; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
98 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
99 | // Get all children of a specific collection |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
100 | // params: $1: parent resource_id |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
101 | static const char *sql_get_children = "select resource_id, nodename, iscollection from Resource where parent_id = $1;"; |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
102 | |
276
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
103 | |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
104 | VFS* pg_vfs_create(Session *sn, Request *rq, pblock *pb) { |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
105 | // resourcepool is required |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
106 | char *resource_pool = pblock_findval("resourcepool", pb); |
276
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
107 | if(!resource_pool) { |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
108 | log_ereport(LOG_MISCONFIG, "pg_vfs_create: missing resourcepool parameter"); |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
109 | return NULL; |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
110 | } |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
111 | |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
112 | // get the resource first (most likely to fail due to misconfig) |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
113 | ResourceData *resdata = resourcepool_lookup(sn, rq, resource_pool, 0); |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
114 | if(!resdata) { |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
115 | log_ereport(LOG_MISCONFIG, "postgresql vfs: resource pool %s not found", resource_pool); |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
116 | return NULL; |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
117 | } |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
118 | // resdata will be freed automatically when the request is finished |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
119 | |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
120 | // Create a new VFS object and a separate instance object |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
121 | // VFS contains fptrs that can be copied from pg_vfs_class |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
122 | // instance contains request specific data (PGconn) |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
123 | VFS *vfs = pool_malloc(sn->pool, sizeof(VFS)); |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
124 | if(!vfs) { |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
125 | return NULL; |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
126 | } |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
127 | |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
128 | PgVFS *vfs_priv = pool_malloc(sn->pool, sizeof(PgVFS)); |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
129 | if(!vfs_priv) { |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
130 | pool_free(sn->pool, vfs); |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
131 | return NULL; |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
132 | } |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
133 | vfs_priv->connection = resdata->data; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
134 | vfs_priv->pg_resource = resdata; |
276
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
135 | |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
136 | memcpy(vfs, &pg_vfs_class, sizeof(VFS)); |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
137 | vfs->flags = 0; |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
138 | vfs->instance = vfs_priv; |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
139 | |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
140 | return vfs; |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
141 | } |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
142 | |
0cb4eda146c4
add function to create a postgresql-based VFS
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
275
diff
changeset
|
143 | |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
144 | int pg_resolve_path(VFSContext *ctx, const char *path, int64_t *parent_id, int64_t *resource_id, const char **resource_name, WSBool *iscollection) { |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
145 | // basic path validation |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
146 | if(!path) return 1; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
147 | size_t pathlen = strlen(path); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
148 | if(pathlen == 0) return 1; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
149 | if(path[0] != '/') { |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
150 | return 1; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
151 | } |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
152 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
153 | // get last node of path |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
154 | *resource_name = util_resource_name(path); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
155 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
156 | VFS *vfs = ctx->vfs; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
157 | PgVFS *pg = vfs->instance; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
158 | |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
159 | const char *sql = pathlen == 1 ? sql_get_root : sql_resolve_path; |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
160 | PGresult *result = PQexecParams( |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
161 | pg->connection, |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
162 | sql, |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
163 | 1, // number of parameters |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
164 | NULL, |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
165 | &path, // parameter value |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
166 | NULL, |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
167 | NULL, |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
168 | 0); // 0: result in text format |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
169 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
170 | if(!result) return 1; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
171 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
172 | int ret = 1; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
173 | int nfields = PQnfields(result); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
174 | int nrows = PQntuples(result); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
175 | if(nrows == 1 && nfields == 4) { |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
176 | char *resource_id_str = PQgetvalue(result, 0, 0); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
177 | char *parent_id_str = PQgetvalue(result, 0, 1); |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
178 | char *iscol = PQgetvalue(result, 0, 3); |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
179 | if(resource_id_str && parent_id_str) { |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
180 | if(util_strtoint(resource_id_str, resource_id)) { |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
181 | ret = 0; // success |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
182 | } |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
183 | // optionally get parent_id |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
184 | util_strtoint(parent_id_str, parent_id); |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
185 | } |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
186 | if(iscol) { |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
187 | *iscollection = iscol[0] == 't' ? TRUE : FALSE; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
188 | } |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
189 | } else { |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
190 | ctx->vfs_errno = ENOENT; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
191 | } |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
192 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
193 | PQclear(result); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
194 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
195 | return ret; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
196 | } |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
197 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
198 | |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
199 | /* -------------------------- VFS functions -------------------------- */ |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
200 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
201 | SYS_FILE pg_vfs_open(VFSContext *ctx, const char *path, int oflags) { |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
202 | const char *resname; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
203 | int64_t resource_id, parent_id; |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
204 | resource_id = -1; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
205 | parent_id = -1; |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
206 | WSBool iscollection; |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
207 | if(pg_resolve_path(ctx, path, &parent_id, &resource_id, &resname, &iscollection)) { |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
208 | return NULL; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
209 | } |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
210 | |
278
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
211 | VFSFile *file = pool_malloc(ctx->pool, sizeof(VFSFile)); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
212 | if(!file) { |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
213 | return NULL; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
214 | } |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
215 | PgFile *pgfile = pool_malloc(ctx->pool, sizeof(PgFile)); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
216 | if(!pgfile) { |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
217 | pool_free(ctx->pool, file); |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
218 | return NULL; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
219 | } |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
220 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
221 | pgfile->iscollection = iscollection; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
222 | pgfile->resource_id = resource_id; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
223 | pgfile->parent_id = parent_id; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
224 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
225 | file->ctx = ctx; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
226 | file->io = iscollection ? NULL : &pg_vfs_io_class; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
227 | file->fd = -1; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
228 | file->data = pgfile; |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
229 | |
38bf7b42b58c
implement pg_vfs_open
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
276
diff
changeset
|
230 | return file; |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
231 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
232 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
233 | int pg_vfs_stat(VFSContext *ctx, const char *path, struct stat *buf) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
234 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
235 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
236 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
237 | int pg_vfs_fstat(VFSContext *ctx, SYS_FILE fd, struct stat *buf) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
238 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
239 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
240 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
241 | VFS_DIR pg_vfs_opendir(VFSContext *ctx, const char *path) { |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
242 | VFSFile *file = pg_vfs_open(ctx, path, O_RDONLY); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
243 | if(!file) return NULL; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
244 | return pg_vfs_fdopendir(ctx, file); |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
245 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
246 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
247 | VFS_DIR pg_vfs_fdopendir(VFSContext *ctx, SYS_FILE fd) { |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
248 | PgFile *pg = fd->data; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
249 | if(!pg->iscollection) { |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
250 | ctx->vfs_errno = ENOTDIR; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
251 | return NULL; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
252 | } |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
253 | |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
254 | VFSDir *dir = pool_malloc(ctx->pool, sizeof(VFSDir)); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
255 | if(!dir) { |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
256 | fd->io->close(fd); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
257 | ctx->vfs_errno = ENOMEM; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
258 | return NULL; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
259 | } |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
260 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
261 | PgDir *pgdir = pool_malloc(ctx->pool, sizeof(PgDir)); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
262 | if(!pgdir) { |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
263 | fd->io->close(fd); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
264 | pool_free(ctx->pool, dir); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
265 | ctx->vfs_errno = ENOMEM; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
266 | return NULL; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
267 | } |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
268 | memset(pgdir, 0, sizeof(PgDir)); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
269 | pgdir->file = fd; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
270 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
271 | dir->ctx = ctx; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
272 | dir->io = &pg_vfs_dirio_class; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
273 | dir->data = pgdir; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
274 | dir->fd = -1; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
275 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
276 | return dir; |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
277 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
278 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
279 | int pg_vfs_mkdir(VFSContext *ctx, const char *path) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
280 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
281 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
282 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
283 | int pg_vfs_unlink(VFSContext *ctx, const char *path) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
284 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
285 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
286 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
287 | int pg_vfs_rmdir(VFSContext *Ctx, const char *path) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
288 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
289 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
290 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
291 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
292 | /* -------------------------- VFS_IO functions -------------------------- */ |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
293 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
294 | ssize_t pg_vfs_io_read(SYS_FILE fd, void *buf, size_t nbyte) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
295 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
296 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
297 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
298 | ssize_t pg_vfs_io_write(SYS_FILE fd, const void *buf, size_t nbyte) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
299 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
300 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
301 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
302 | ssize_t pg_vfs_io_pread(SYS_FILE fd, void *buf, size_t nbyte, off_t offset) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
303 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
304 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
305 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
306 | ssize_t pg_vfs_io_pwrite(SYS_FILE fd, const void *buf, size_t nbyte, off_t offset) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
307 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
308 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
309 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
310 | off_t pg_vfs_io_seek(SYS_FILE fd, off_t offset, int whence) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
311 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
312 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
313 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
314 | void pg_vfs_io_close(SYS_FILE fd) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
315 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
316 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
317 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
318 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
319 | /* -------------------------- VFS_DIRIO functions -------------------------- */ |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
320 | |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
321 | static int load_dir(VFSDir *dir, PgDir *pg) { |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
322 | VFS *vfs = dir->ctx->vfs; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
323 | PgVFS *pgvfs = vfs->instance; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
324 | PgFile *pgfd = pg->file->data; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
325 | PgDir *pgdir = dir->data; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
326 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
327 | char resid_param[32]; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
328 | snprintf(resid_param, 32, "%" PRId64, pgfd->resource_id); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
329 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
330 | const char *param = resid_param; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
331 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
332 | PGresult *result = PQexecParams( |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
333 | pgvfs->connection, |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
334 | sql_get_children, |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
335 | 1, // number of parameters |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
336 | NULL, |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
337 | ¶m, // param: parent resource_id |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
338 | NULL, |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
339 | NULL, |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
340 | 0); // 0: result in text format |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
341 | if(!result) return 1; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
342 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
343 | pgdir->result = result; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
344 | pgdir->nrows = PQntuples(result); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
345 | return 0; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
346 | } |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
347 | |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
348 | int pg_vfs_dirio_readdir(VFS_DIR dir, VFS_ENTRY *entry, int getstat) { |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
349 | PgDir *pg = dir->data; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
350 | if(!pg->result) { |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
351 | if(load_dir(dir, pg)) { |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
352 | return 0; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
353 | } |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
354 | } |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
355 | |
279
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
356 | if(pg->row >= pg->nrows) { |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
357 | return 0; // EOF |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
358 | } |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
359 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
360 | entry->name = PQgetvalue(pg->result, pg->row, 1); |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
361 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
362 | // TODO: stat |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
363 | |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
364 | pg->row++; |
79029fe26aae
add basic postgresql vfs directory functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
278
diff
changeset
|
365 | return 1; |
275
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
366 | } |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
367 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
368 | void pg_vfs_dirio_close(VFS_DIR dir) { |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
369 | |
535004faa1a5
add empty postgresql VFS functions
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
diff
changeset
|
370 | } |