← Back to branch summary

~ubuntu-branches/debian/experimental/postgresql-11/experimental

« back to all changes in this revision

Viewing changes to src/test/regress/input/largeobject.source

  • Committer: Package Import Robot
  • Author(s): Christoph Berg
  • Date: 2018-05-22 14:19:08 UTC
  • Revision ID: package-import@ubuntu.com-20180522141908-0oy9ujs1b5vrda74
Tags: upstream-11~beta1
Import upstream version 11~beta1

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/test/regress/input/largeobject.source
 
1
--
 
2
-- Test large object support
 
3
--
 
4
 
 
5
-- ensure consistent test output regardless of the default bytea format
 
6
SET bytea_output TO escape;
 
7
 
 
8
-- Load a file
 
9
CREATE TABLE lotest_stash_values (loid oid, fd integer);
 
10
-- lo_creat(mode integer) returns oid
 
11
-- The mode arg to lo_creat is unused, some vestigal holdover from ancient times
 
12
-- returns the large object id
 
13
INSERT INTO lotest_stash_values (loid) SELECT lo_creat(42);
 
14
 
 
15
-- Test ALTER LARGE OBJECT
 
16
CREATE ROLE regress_lo_user;
 
17
DO $$
 
18
  BEGIN
 
19
    EXECUTE 'ALTER LARGE OBJECT ' || (select loid from lotest_stash_values)
 
20
                || ' OWNER TO regress_lo_user';
 
21
  END
 
22
$$;
 
23
SELECT
 
24
        rol.rolname
 
25
FROM
 
26
        lotest_stash_values s
 
27
        JOIN pg_largeobject_metadata lo ON s.loid = lo.oid
 
28
        JOIN pg_authid rol ON lo.lomowner = rol.oid;
 
29
 
 
30
-- NOTE: large objects require transactions
 
31
BEGIN;
 
32
 
 
33
-- lo_open(lobjId oid, mode integer) returns integer
 
34
-- The mode parameter to lo_open uses two constants:
 
35
--   INV_READ  = 0x20000
 
36
--   INV_WRITE = 0x40000
 
37
-- The return value is a file descriptor-like value which remains valid for the
 
38
-- transaction.
 
39
UPDATE lotest_stash_values SET fd = lo_open(loid, CAST(x'20000' | x'40000' AS integer));
 
40
 
 
41
-- loread/lowrite names are wonky, different from other functions which are lo_*
 
42
-- lowrite(fd integer, data bytea) returns integer
 
43
-- the integer is the number of bytes written
 
44
SELECT lowrite(fd, '
 
45
I wandered lonely as a cloud
 
46
That floats on high o''er vales and hills,
 
47
When all at once I saw a crowd,
 
48
A host, of golden daffodils;
 
49
Beside the lake, beneath the trees,
 
50
Fluttering and dancing in the breeze.
 
51
 
 
52
Continuous as the stars that shine
 
53
And twinkle on the milky way,
 
54
They stretched in never-ending line
 
55
Along the margin of a bay:
 
56
Ten thousand saw I at a glance,
 
57
Tossing their heads in sprightly dance.
 
58
 
 
59
The waves beside them danced; but they
 
60
Out-did the sparkling waves in glee:
 
61
A poet could not but be gay,
 
62
In such a jocund company:
 
63
I gazed--and gazed--but little thought
 
64
What wealth the show to me had brought:
 
65
 
 
66
For oft, when on my couch I lie
 
67
In vacant or in pensive mood,
 
68
They flash upon that inward eye
 
69
Which is the bliss of solitude;
 
70
And then my heart with pleasure fills,
 
71
And dances with the daffodils.
 
72
 
 
73
         -- William Wordsworth
 
74
') FROM lotest_stash_values;
 
75
 
 
76
-- lo_close(fd integer) returns integer
 
77
-- return value is 0 for success, or <0 for error (actually only -1, but...)
 
78
SELECT lo_close(fd) FROM lotest_stash_values;
 
79
 
 
80
END;
 
81
 
 
82
-- Copy to another large object.
 
83
-- Note: we intentionally don't remove the object created here;
 
84
-- it's left behind to help test pg_dump.
 
85
 
 
86
SELECT lo_from_bytea(0, lo_get(loid)) AS newloid FROM lotest_stash_values
 
87
\gset
 
88
 
 
89
-- Add a comment to it, as well, for pg_dump/pg_upgrade testing.
 
90
COMMENT ON LARGE OBJECT :newloid IS 'I Wandered Lonely as a Cloud';
 
91
 
 
92
-- Read out a portion
 
93
BEGIN;
 
94
UPDATE lotest_stash_values SET fd=lo_open(loid, CAST(x'20000' | x'40000' AS integer));
 
95
 
 
96
-- lo_lseek(fd integer, offset integer, whence integer) returns integer
 
97
-- offset is in bytes, whence is one of three values:
 
98
--  SEEK_SET (= 0) meaning relative to beginning
 
99
--  SEEK_CUR (= 1) meaning relative to current position
 
100
--  SEEK_END (= 2) meaning relative to end (offset better be negative)
 
101
-- returns current position in file
 
102
SELECT lo_lseek(fd, 104, 0) FROM lotest_stash_values;
 
103
 
 
104
-- loread/lowrite names are wonky, different from other functions which are lo_*
 
105
-- loread(fd integer, len integer) returns bytea
 
106
SELECT loread(fd, 28) FROM lotest_stash_values;
 
107
 
 
108
SELECT lo_lseek(fd, -19, 1) FROM lotest_stash_values;
 
109
 
 
110
SELECT lowrite(fd, 'n') FROM lotest_stash_values;
 
111
 
 
112
SELECT lo_tell(fd) FROM lotest_stash_values;
 
113
 
 
114
SELECT lo_lseek(fd, -744, 2) FROM lotest_stash_values;
 
115
 
 
116
SELECT loread(fd, 28) FROM lotest_stash_values;
 
117
 
 
118
SELECT lo_close(fd) FROM lotest_stash_values;
 
119
 
 
120
END;
 
121
 
 
122
-- Test resource management
 
123
BEGIN;
 
124
SELECT lo_open(loid, x'40000'::int) from lotest_stash_values;
 
125
ABORT;
 
126
 
 
127
-- Test truncation.
 
128
BEGIN;
 
129
UPDATE lotest_stash_values SET fd=lo_open(loid, CAST(x'20000' | x'40000' AS integer));
 
130
 
 
131
SELECT lo_truncate(fd, 11) FROM lotest_stash_values;
 
132
SELECT loread(fd, 15) FROM lotest_stash_values;
 
133
 
 
134
SELECT lo_truncate(fd, 10000) FROM lotest_stash_values;
 
135
SELECT loread(fd, 10) FROM lotest_stash_values;
 
136
SELECT lo_lseek(fd, 0, 2) FROM lotest_stash_values;
 
137
SELECT lo_tell(fd) FROM lotest_stash_values;
 
138
 
 
139
SELECT lo_truncate(fd, 5000) FROM lotest_stash_values;
 
140
SELECT lo_lseek(fd, 0, 2) FROM lotest_stash_values;
 
141
SELECT lo_tell(fd) FROM lotest_stash_values;
 
142
 
 
143
SELECT lo_close(fd) FROM lotest_stash_values;
 
144
END;
 
145
 
 
146
-- Test 64-bit large object functions.
 
147
BEGIN;
 
148
UPDATE lotest_stash_values SET fd = lo_open(loid, CAST(x'20000' | x'40000' AS integer));
 
149
 
 
150
SELECT lo_lseek64(fd, 4294967296, 0) FROM lotest_stash_values;
 
151
SELECT lowrite(fd, 'offset:4GB') FROM lotest_stash_values;
 
152
SELECT lo_tell64(fd) FROM lotest_stash_values;
 
153
 
 
154
SELECT lo_lseek64(fd, -10, 1) FROM lotest_stash_values;
 
155
SELECT lo_tell64(fd) FROM lotest_stash_values;
 
156
SELECT loread(fd, 10) FROM lotest_stash_values;
 
157
 
 
158
SELECT lo_truncate64(fd, 5000000000) FROM lotest_stash_values;
 
159
SELECT lo_lseek64(fd, 0, 2) FROM lotest_stash_values;
 
160
SELECT lo_tell64(fd) FROM lotest_stash_values;
 
161
 
 
162
SELECT lo_truncate64(fd, 3000000000) FROM lotest_stash_values;
 
163
SELECT lo_lseek64(fd, 0, 2) FROM lotest_stash_values;
 
164
SELECT lo_tell64(fd) FROM lotest_stash_values;
 
165
 
 
166
SELECT lo_close(fd) FROM lotest_stash_values;
 
167
END;
 
168
 
 
169
-- lo_unlink(lobjId oid) returns integer
 
170
-- return value appears to always be 1
 
171
SELECT lo_unlink(loid) from lotest_stash_values;
 
172
 
 
173
TRUNCATE lotest_stash_values;
 
174
 
 
175
INSERT INTO lotest_stash_values (loid) SELECT lo_import('@abs_srcdir@/data/tenk.data');
 
176
 
 
177
BEGIN;
 
178
UPDATE lotest_stash_values SET fd=lo_open(loid, CAST(x'20000' | x'40000' AS integer));
 
179
 
 
180
-- verify length of large object
 
181
SELECT lo_lseek(fd, 0, 2) FROM lotest_stash_values;
 
182
 
 
183
-- with the default BLKSZ, LOBLKSZ = 2048, so this positions us for a block
 
184
-- edge case
 
185
SELECT lo_lseek(fd, 2030, 0) FROM lotest_stash_values;
 
186
 
 
187
-- this should get half of the value from page 0 and half from page 1 of the
 
188
-- large object
 
189
SELECT loread(fd, 36) FROM lotest_stash_values;
 
190
 
 
191
SELECT lo_tell(fd) FROM lotest_stash_values;
 
192
 
 
193
SELECT lo_lseek(fd, -26, 1) FROM lotest_stash_values;
 
194
 
 
195
SELECT lowrite(fd, 'abcdefghijklmnop') FROM lotest_stash_values;
 
196
 
 
197
SELECT lo_lseek(fd, 2030, 0) FROM lotest_stash_values;
 
198
 
 
199
SELECT loread(fd, 36) FROM lotest_stash_values;
 
200
 
 
201
SELECT lo_close(fd) FROM lotest_stash_values;
 
202
END;
 
203
 
 
204
SELECT lo_export(loid, '@abs_builddir@/results/lotest.txt') FROM lotest_stash_values;
 
205
 
 
206
\lo_import 'results/lotest.txt'
 
207
 
 
208
\set newloid :LASTOID
 
209
 
 
210
-- just make sure \lo_export does not barf
 
211
\lo_export :newloid 'results/lotest2.txt'
 
212
 
 
213
-- This is a hack to test that export/import are reversible
 
214
-- This uses knowledge about the inner workings of large object mechanism
 
215
-- which should not be used outside it.  This makes it a HACK
 
216
SELECT pageno, data FROM pg_largeobject WHERE loid = (SELECT loid from lotest_stash_values)
 
217
EXCEPT
 
218
SELECT pageno, data FROM pg_largeobject WHERE loid = :newloid;
 
219
 
 
220
SELECT lo_unlink(loid) FROM lotest_stash_values;
 
221
 
 
222
TRUNCATE lotest_stash_values;
 
223
 
 
224
\lo_unlink :newloid
 
225
 
 
226
\lo_import 'results/lotest.txt'
 
227
 
 
228
\set newloid_1 :LASTOID
 
229
 
 
230
SELECT lo_from_bytea(0, lo_get(:newloid_1)) AS newloid_2
 
231
\gset
 
232
 
 
233
SELECT md5(lo_get(:newloid_1)) = md5(lo_get(:newloid_2));
 
234
 
 
235
SELECT lo_get(:newloid_1, 0, 20);
 
236
SELECT lo_get(:newloid_1, 10, 20);
 
237
SELECT lo_put(:newloid_1, 5, decode('afafafaf', 'hex'));
 
238
SELECT lo_get(:newloid_1, 0, 20);
 
239
 
 
240
SELECT lo_put(:newloid_1, 4294967310, 'foo');
 
241
SELECT lo_get(:newloid_1);
 
242
SELECT lo_get(:newloid_1, 4294967294, 100);
 
243
 
 
244
\lo_unlink :newloid_1
 
245
\lo_unlink :newloid_2
 
246
 
 
247
-- This object is left in the database for pg_dump test purposes
 
248
SELECT lo_from_bytea(0, E'\\xdeadbeef') AS newloid
 
249
\gset
 
250
 
 
251
SET bytea_output TO hex;
 
252
SELECT lo_get(:newloid);
 
253
 
 
254
-- Create one more object that we leave behind for testing pg_dump/pg_upgrade;
 
255
-- this one intentionally has an OID in the system range
 
256
SELECT lo_create(3001);
 
257
 
 
258
COMMENT ON LARGE OBJECT 3001 IS 'testing comments';
 
259
 
 
260
-- Clean up
 
261
DROP TABLE lotest_stash_values;
 
262
 
 
263
DROP ROLE regress_lo_user;