rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-30 11:30:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

successfully upload and download the test_load extension

Browse Source
This commit is contained in:
Alek Westover
2023-06-16 16:51:08 -04:00
parent e07d5d00e9
commit 1b7ab6d468
4 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
alek/env.txt
View File

@@ -1 +1 @@
{'repo_dir': PosixPath('/home/alek/Desktop/neonX/test_output/test_file_download[debug-pg14]/repo'), 'rust_log_override': None, 'port_distributor': <fixtures.neon_fixtures.PortDistributor object at 0x7f500e15f130>, 's3_mock_server': <fixtures.neon_fixtures.MockS3Server object at 0x7f500e15ed70>, 'neon_cli': <fixtures.neon_fixtures.NeonCli object at 0x7f500c6c7af0>, 'endpoints': <fixtures.neon_fixtures.EndpointFactory object at 0x7f500c6c7a60>, 'safekeepers': [Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f500c6c7a90>, port=SafekeeperPort(pg=15007, http=15008), id=1, running=True), Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f500c6c7a90>, port=SafekeeperPort(pg=15009, http=15010), id=2, running=True), Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f500c6c7a90>, port=SafekeeperPort(pg=15011, http=15012), id=3, running=True)], 'broker': NeonBroker(logfile=PosixPath('/home/alek/Desktop/neonX/test_output/test_file_download[debug-pg14]/repo/storage_broker.log'), port=15004, neon_binpath=PosixPath('/home/alek/Desktop/neonX/target/debug'), handle=<Popen: returncode: None args: ['/home/alek/Desktop/neonX/target/debug/stora...>), 'remote_storage': S3Storage(bucket_name='test_file_download', bucket_region='us-east-1', access_key='test', secret_key='test', endpoint='http://127.0.0.1:15003', prefix_in_bucket=None), 'remote_storage_users': <RemoteStorageUsers.PAGESERVER: 1>, 'pg_version': '14', 'neon_binpath': PosixPath('/home/alek/Desktop/neonX/target/debug'), 'pg_distrib_dir': PosixPath('/home/alek/Desktop/neonX/pg_install'), 'endpoint_counter': 0, 'initial_tenant': `TenantId("861cf3b88b5e53ac412227ed9fd26d10"), 'initial_timeline': TimelineId("04179cf8c30a9d3652cd39d790b4e4b7"), 'pageserver': <fixtures.neon_fixtures.NeonPageserver object at 0x7f500c6c7970>}
{'repo_dir': PosixPath('/home/alek/Desktop/neonX/test_output/test_file_download[debug-pg14]/repo'), 'rust_log_override': None, 'port_distributor': <fixtures.neon_fixtures.PortDistributor object at 0x7f15e2763130>, 's3_mock_server': <fixtures.neon_fixtures.MockS3Server object at 0x7f15e2762d70>, 'neon_cli': <fixtures.neon_fixtures.NeonCli object at 0x7f15e09c7a30>, 'endpoints': <fixtures.neon_fixtures.EndpointFactory object at 0x7f15e09c79a0>, 'safekeepers': [Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f15e09c7a00>, port=SafekeeperPort(pg=15004, http=15005), id=1, running=True), Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f15e09c7a00>, port=SafekeeperPort(pg=15006, http=15007), id=2, running=True), Safekeeper(env=<fixtures.neon_fixtures.NeonEnv object at 0x7f15e09c7a00>, port=SafekeeperPort(pg=15008, http=15009), id=3, running=True)], 'broker': NeonBroker(logfile=PosixPath('/home/alek/Desktop/neonX/test_output/test_file_download[debug-pg14]/repo/storage_broker.log'), port=15001, neon_binpath=PosixPath('/home/alek/Desktop/neonX/target/debug'), handle=<Popen: returncode: None args: ['/home/alek/Desktop/neonX/target/debug/stora...>), 'remote_storage': S3Storage(bucket_name='test_file_download', bucket_region='us-east-1', access_key='test', secret_key='test', endpoint='http://127.0.0.1:15000', prefix_in_bucket=None), 'remote_storage_users': <RemoteStorageUsers.PAGESERVER: 1>, 'pg_version': '14', 'neon_binpath': PosixPath('/home/alek/Desktop/neonX/target/debug'), 'pg_distrib_dir': PosixPath('/home/alek/Desktop/neonX/pg_install'), 'endpoint_counter': 0, 'initial_tenant': `TenantId("1a50a17881f6b200e570982460dbf411"), 'initial_timeline': TimelineId("835f77900b841e88d7f7a8721ad3d2ba"), 'pageserver': <fixtures.neon_fixtures.NeonPageserver object at 0x7f15e09c78b0>}

2
alek/output.txt
View File

@@ -1 +1 @@
NoneNone
[(0, '0'), (1, '2'), (2, '4'), (3, '6'), (4, '8'), (5, '10'), (6, '12'), (7, '14'), (8, '16'), (9, '18'), (10, '20'), (11, '22'), (12, '24'), (13, '26'), (14, '28'), (15, '30'), (16, '32'), (17, '34'), (18, '36'), (19, '38'), (20, '40'), (21, '42'), (22, '44'), (23, '46'), (24, '48'), (25, '50'), (26, '52'), (27, '54'), (28, '56'), (29, '58'), (30, '60'), (31, '62'), (32, '64'), (33, '66'), (34, '68'), (35, '70'), (36, '72'), (37, '74'), (38, '76'), (39, '78'), (40, '80'), (41, '82'), (42, '84'), (43, '86'), (44, '88'), (45, '90'), (46, '92'), (47, '94'), (48, '96'), (49, '98'), (50, '100'), (51, '102'), (52, '104'), (53, '106'), (54, '108'), (55, '110'), (56, '112'), (57, '114'), (58, '116'), (59, '118'), (60, '120'), (61, '122'), (62, '124'), (63, '126'), (64, '128'), (65, '130'), (66, '132'), (67, '134'), (68, '136'), (69, '138'), (70, '140'), (71, '142'), (72, '144'), (73, '146'), (74, '148'), (75, '150'), (76, '152'), (77, '154'), (78, '156'), (79, '158'), (80, '160'), (81, '162'), (82, '164'), (83, '166'), (84, '168'), (85, '170'), (86, '172'), (87, '174'), (88, '176'), (89, '178'), (90, '180'), (91, '182'), (92, '184'), (93, '186'), (94, '188'), (95, '190'), (96, '192'), (97, '194'), (98, '196'), (99, '198')]

1
alek/win.txt Normal file
View File

@@ -0,0 +1 @@
[('neon_utils', '1.0', None, 'neon_utils - small useful functions'), ('pg_buffercache', '1.3', None, 'examine the shared buffer cache'), ('pageinspect', '1.9', None, 'inspect the contents of database pages at a low level'), ('neon', '1.0', None, 'cloud storage for PostgreSQL'), ('test_load', '1.0', None, 'Mock extension'), ('plpgsql', '1.0', '1.0', 'PL/pgSQL procedural language'), ('neon_test_utils', '1.0', None, 'helpers for neon testing and debugging'), ('pg_prewarm', '1.2', None, 'prewarm relation data'), ('hnsw', '0.1.0', None, 'hNsw index')]

18
test_runner/regress/test_download_extensions.py
View File

@@ -67,13 +67,19 @@ def test_file_download(neon_env_builder: NeonEnvBuilder):
endpoint = env.endpoints.create_start("test_file_download", tenant_id=tenant)
with closing(endpoint.connect()) as conn:
with conn.cursor() as cur:
# cur.execute("CREATE EXTENSION test_load");
cur.execute("CREATE TABLE t(key int primary key, value text)")
for i in range(100):
cur.execute(f"insert into t values({i}, {2*i})")
cur.execute("select * from t")
x = cur.fetchall()
log.info(x)
# TODO: we should see the test_ext extension here
other = cur.execute("SELECT * FROM pg_catalog.pg_tables;")
whatsup = cur.execute("select * from pg_available_extensions;")
with open("alek/output.txt", "w") as f:
f.write(str(whatsup) + str(other))
# this is returning None????
cur.execute("SELECT * FROM pg_available_extensions")
x = cur.fetchall()
with open("alek/win.txt", "w") as f:
f.write(str(x))
log.info(x)
endpoint.stop()
env.pageserver.http_client().tenant_detach(tenant)