Compare commits
21 Commits
python-0.2
...
python-0.2
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
eca8d1b428 | ||
|
|
e1e85e2391 | ||
|
|
0f8e946461 | ||
|
|
ad8a40129a | ||
|
|
f2dcd4453c | ||
|
|
48c3718235 | ||
|
|
2a1d751cf5 | ||
|
|
7f87fc2e25 | ||
|
|
b793c02415 | ||
|
|
95bd089366 | ||
|
|
dbb7248f67 | ||
|
|
d527b10f22 | ||
|
|
37d72b333a | ||
|
|
40146c5eff | ||
|
|
87d9ceec0a | ||
|
|
4dc2104f93 | ||
|
|
89b445b99d | ||
|
|
ef7c158e4b | ||
|
|
4b6c5a23db | ||
|
|
d0557049c0 | ||
|
|
e6d3cdab12 |
8
.github/workflows/main.yml
vendored
8
.github/workflows/main.yml
vendored
@@ -4,6 +4,7 @@ jobs:
|
|||||||
dataservices-api:
|
dataservices-api:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
strategy:
|
strategy:
|
||||||
|
fail-fast: false
|
||||||
matrix:
|
matrix:
|
||||||
pg_version: [10, 12]
|
pg_version: [10, 12]
|
||||||
env:
|
env:
|
||||||
@@ -11,6 +12,9 @@ jobs:
|
|||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v1
|
- uses: actions/checkout@v1
|
||||||
|
|
||||||
|
- name: Set CLOUDSDK_PYTHON path
|
||||||
|
run: echo '::set-env name=CLOUDSDK_PYTHON::/usr/bin/python'
|
||||||
|
|
||||||
- name: Setup gcloud authentication
|
- name: Setup gcloud authentication
|
||||||
uses: GoogleCloudPlatform/github-actions/setup-gcloud@master
|
uses: GoogleCloudPlatform/github-actions/setup-gcloud@master
|
||||||
with:
|
with:
|
||||||
@@ -48,9 +52,9 @@ jobs:
|
|||||||
timeout-minutes: 5
|
timeout-minutes: 5
|
||||||
|
|
||||||
- name: Run server tests
|
- name: Run server tests
|
||||||
run: docker-compose -f docker-compose.yaml exec -T postgres-server bash -c "cd /dataservices-api/server/extension/ && sudo make clean all install installcheck || (cat /dataservices-api/server/extension/test_out/regression.diffs && false)"
|
run: docker-compose -f docker-compose.yaml exec -T postgres-server bash -c "cd /dataservices-api/server/extension/ && sudo make clean all install installcheck || (cat /dataservices-api/server/extension/test/regression.diffs && false)"
|
||||||
timeout-minutes: 5
|
timeout-minutes: 5
|
||||||
|
|
||||||
- name: Run client tests
|
- name: Run client tests
|
||||||
run: docker-compose -f docker-compose.yaml exec -T postgres-server bash -c "sudo createuser publicuser --no-createrole --no-createdb --no-superuser -U postgres && cd /dataservices-api/client/ && sudo make clean all install installcheck || (cat /home/ubuntu/dataservices-api/client/test_out/regression.diffs && false)"
|
run: docker-compose -f docker-compose.yaml exec -T postgres-server bash -c "sudo createuser publicuser --no-createrole --no-createdb --no-superuser -U postgres && cd /dataservices-api/client/ && sudo make clean all install installcheck || (cat /dataservices-api/client/test/regression.diffs && false)"
|
||||||
timeout-minutes: 5
|
timeout-minutes: 5
|
||||||
|
|||||||
12
NEWS.md
12
NEWS.md
@@ -1,3 +1,15 @@
|
|||||||
|
Sep 23th, 2020
|
||||||
|
==============
|
||||||
|
* Version `0.23.3` of the Python library
|
||||||
|
* Change HERE batch geocoding URL
|
||||||
|
|
||||||
|
Apr 7th, 2020
|
||||||
|
=============
|
||||||
|
* Version `0.30.0` of the client extension
|
||||||
|
* PG12: Use postgis_raster instead of custom geomval.
|
||||||
|
* Version `0.39.0` of the server extension
|
||||||
|
* PG12: Use postgis_raster instead of custom geomval.
|
||||||
|
|
||||||
Mar 17th, 2020
|
Mar 17th, 2020
|
||||||
==============
|
==============
|
||||||
* Version `0.29.0` of the client extension
|
* Version `0.29.0` of the client extension
|
||||||
|
|||||||
1
client/.gitignore
vendored
1
client/.gitignore
vendored
@@ -9,3 +9,4 @@ cdb_geocoder_client--0.0.1.sql
|
|||||||
cdb_geocoder_client--0.1.0.sql
|
cdb_geocoder_client--0.1.0.sql
|
||||||
cdb_geocoder_client--0.2.0.sql
|
cdb_geocoder_client--0.2.0.sql
|
||||||
cdb_geocoder_client--0.3.0.sql
|
cdb_geocoder_client--0.3.0.sql
|
||||||
|
cdb_dataservices_client.control
|
||||||
|
|||||||
111
client/Makefile
111
client/Makefile
@@ -1,27 +1,30 @@
|
|||||||
# Makefile to generate the extension out of separate sql source files.
|
# Makefile to generate the extension out of separate sql source files.
|
||||||
# Once a version is released, it is not meant to be changed. E.g: once version 0.0.1 is out, it SHALL NOT be changed.
|
# Once a version is released, it is not meant to be changed. E.g: once version 0.0.1 is out, it SHALL NOT be changed.
|
||||||
EXTENSION = cdb_dataservices_client
|
EXTENSION = cdb_dataservices_client
|
||||||
EXTVERSION = $(shell grep default_version $(EXTENSION).control | sed -e "s/default_version[[:space:]]*=[[:space:]]*'\([^']*\)'/\1/")
|
EXTVERSION = 0.30.0
|
||||||
|
|
||||||
# The new version to be generated from templates
|
# The new version to be generated from templates
|
||||||
SED = sed
|
SED ?= sed
|
||||||
ERB = erb
|
ERB ?= erb
|
||||||
REPLACEMENTS = -i 's/$(EXTVERSION)/$(NEW_VERSION)/g'
|
AWK ?= awk
|
||||||
NEW_EXTENSION_ARTIFACT = $(EXTENSION)--$(EXTVERSION).sql
|
|
||||||
AWK = awk
|
|
||||||
|
|
||||||
# Parallel support macros
|
# Parallel support macros
|
||||||
PG_CONFIG = pg_config
|
PG_CONFIG ?= pg_config
|
||||||
PG_PARALLEL := $(shell $(PG_CONFIG) --version | ($(AWK) '{$$2*=1000; if ($$2 >= 9600) print 1; else print 0;}' 2> /dev/null || echo 0))
|
PG_PARALLEL := $(shell $(PG_CONFIG) --version | ($(AWK) '{$$2*=1000; if ($$2 >= 9600) print 1; else print 0;}' 2> /dev/null || echo 0))
|
||||||
|
|
||||||
# PG12 compatibility
|
# PG12 compatibility
|
||||||
PG_VERSION := $(shell $(PG_CONFIG) --version | $(AWK) '{split($$2,a,"."); print a[1]}')
|
PG_VERSION := $(shell $(PG_CONFIG) --version | $(AWK) '{split($$2,a,"."); print a[1]}')
|
||||||
PG_12_GE := $(shell [ $(PG_VERSION) -ge 12 ] && echo true)
|
PG_12_GE := $(shell [ $(PG_VERSION) -ge 12 ] && echo true)
|
||||||
PLPYTHONU := plpythonu
|
PLPYTHONU := plpythonu
|
||||||
|
POSTGIS := postgis
|
||||||
ifeq ($(PG_12_GE), true)
|
ifeq ($(PG_12_GE), true)
|
||||||
PLPYTHONU := plpython3u
|
PLPYTHONU := plpython3u
|
||||||
|
POSTGIS := postgis, postgis_raster
|
||||||
endif
|
endif
|
||||||
|
|
||||||
|
REPLACEMENTS = -e 's/@@EXTVERSION@@/$(EXTVERSION)/g' -e 's/@@plpythonu@@/$(PLPYTHONU)/g' -e 's/@@postgis@@/$(POSTGIS)/g'
|
||||||
|
NEW_EXTENSION_ARTIFACT = $(EXTENSION)--$(EXTVERSION).sql
|
||||||
|
|
||||||
# OLD_VERSIONS = $(wildcard old_versions/*.sql)
|
# OLD_VERSIONS = $(wildcard old_versions/*.sql)
|
||||||
# DATA = $(NEW_EXTENSION_ARTIFACT) \
|
# DATA = $(NEW_EXTENSION_ARTIFACT) \
|
||||||
# $(OLD_VERSIONS) \
|
# $(OLD_VERSIONS) \
|
||||||
@@ -51,7 +54,6 @@ TEMPLATE_FILES = $(wildcard $(TEMPLATE_DIR)/*.erb)
|
|||||||
GENERATED_SQL_FILES = $(patsubst $(TEMPLATE_DIR)/%.erb, $(SOURCES_DATA_DIR)/%.sql, $(TEMPLATE_FILES))
|
GENERATED_SQL_FILES = $(patsubst $(TEMPLATE_DIR)/%.erb, $(SOURCES_DATA_DIR)/%.sql, $(TEMPLATE_FILES))
|
||||||
|
|
||||||
# postgres build stuff
|
# postgres build stuff
|
||||||
PG_CONFIG = pg_config
|
|
||||||
PGXS := $(shell $(PG_CONFIG) --pgxs)
|
PGXS := $(shell $(PG_CONFIG) --pgxs)
|
||||||
include $(PGXS)
|
include $(PGXS)
|
||||||
|
|
||||||
@@ -62,29 +64,21 @@ SOURCES_DATA = $(wildcard $(SOURCES_DATA_DIR)/*.sql) $(GENERATED_SQL_FILES)
|
|||||||
|
|
||||||
$(NEW_EXTENSION_ARTIFACT): $(SOURCES_DATA)
|
$(NEW_EXTENSION_ARTIFACT): $(SOURCES_DATA)
|
||||||
rm -f $@
|
rm -f $@
|
||||||
cat $(SOURCES_DATA_DIR)/*.sql | \
|
cat $(SOURCES_DATA_DIR)/*.sql >> $@
|
||||||
$(SED) -e 's/@@plpythonu@@/$(PLPYTHONU)/g' >> $@
|
|
||||||
ifeq ($(PG_PARALLEL), 0)
|
|
||||||
# Remove PARALLEL in aggregates and functions
|
|
||||||
$(eval TMPFILE := $(shell mktemp /tmp/$(basename $0).XXXXXXXX))
|
|
||||||
$(SED) -e 's/PARALLEL \= [A-Z]*,/''/g' \
|
|
||||||
-e 's/PARALLEL [A-Z]*/''/g' $@ > $(TMPFILE)
|
|
||||||
mv $(TMPFILE) $@
|
|
||||||
endif
|
|
||||||
|
|
||||||
.PHONY: all
|
.PHONY: all
|
||||||
all: $(DATA)
|
all: $(DATA)
|
||||||
|
|
||||||
.PHONY: release
|
.PHONY: release
|
||||||
release: $(EXTENSION).control $(SOURCES_DATA)
|
release: $(SOURCES_DATA)
|
||||||
test -n "$(NEW_VERSION)" # $$NEW_VERSION VARIABLE MISSING. Eg. make release NEW_VERSION=0.x.0
|
test -n "$(NEW_VERSION)" # $$NEW_VERSION VARIABLE MISSING. Eg. make release NEW_VERSION=0.x.0
|
||||||
git mv *.sql old_versions
|
git mv *.sql old_versions
|
||||||
$(SED) $(REPLACEMENTS) $(EXTENSION).control
|
|
||||||
git add $(EXTENSION).control
|
|
||||||
cat $(SOURCES_DATA_DIR)/*.sql > $(EXTENSION)--$(NEW_VERSION).sql
|
cat $(SOURCES_DATA_DIR)/*.sql > $(EXTENSION)--$(NEW_VERSION).sql
|
||||||
git add $(EXTENSION)--$(NEW_VERSION).sql
|
git add $(EXTENSION)--$(NEW_VERSION).sql
|
||||||
$(ERB) version=$(NEW_VERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql
|
$(ERB) version=$(NEW_VERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql
|
||||||
$(ERB) version=$(EXTVERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql
|
$(ERB) version=$(EXTVERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql
|
||||||
|
$(SED) -i -e 's/^EXTVERSION =.*/EXTVERSION = $(NEW_VERSION)/g' Makefile
|
||||||
|
git add Makefile
|
||||||
@echo
|
@echo
|
||||||
@echo "Please review the file $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql and add any code needed to upgrade $(EXTVERSION) to $(NEW_VERSION)"
|
@echo "Please review the file $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql and add any code needed to upgrade $(EXTVERSION) to $(NEW_VERSION)"
|
||||||
@echo "Please review the file $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql and add any code needed to downgrade $(NEW_VERSION) to $(EXTVERSION)"
|
@echo "Please review the file $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql and add any code needed to downgrade $(NEW_VERSION) to $(EXTVERSION)"
|
||||||
@@ -96,70 +90,29 @@ devclean:
|
|||||||
rm -f $(NEW_EXTENSION_ARTIFACT)
|
rm -f $(NEW_EXTENSION_ARTIFACT)
|
||||||
rm -f $(GENERATED_SQL_FILES)
|
rm -f $(GENERATED_SQL_FILES)
|
||||||
|
|
||||||
clean: restore_copies
|
# Replace variables (and PARALLEL tags if necessary) and deploy files
|
||||||
|
.PHONY: replace_variables_and_deploy
|
||||||
# If needed remove PARALLEL tags from the release files
|
replace_variables_and_deploy: $(NEW_EXTENSION_ARTIFACT)
|
||||||
release_remove_parallel_deploy:
|
mkdir -p '$(DESTDIR)$(datadir)/extension/'; \
|
||||||
ifeq ($(PG_PARALLEL), 0)
|
|
||||||
for n in $(wildcard old_versions/*.sql *.sql); do \
|
for n in $(wildcard old_versions/*.sql *.sql); do \
|
||||||
$(eval TMPFILE := $(shell mktemp /tmp/XXXXXXXXXX)) \
|
$(eval TMPFILE := $(shell mktemp /tmp/XXXXXXXXXX)) \
|
||||||
$(SED) -e 's/PARALLEL \= [A-Z]*,/''/g' -e 's/PARALLEL [A-Z]*/''/g' $$n > $(TMPFILE); \
|
if [ "$(PG_PARALLEL)" -eq "0" ]; then \
|
||||||
mv $(TMPFILE) $$n; \
|
$(SED) -e 's/PARALLEL \= [A-Z]*,/''/g' -e 's/PARALLEL [A-Z]*/''/g' $$n > $(TMPFILE); \
|
||||||
|
mv $(TMPFILE) $$n; \
|
||||||
|
fi; \
|
||||||
|
$(SED) $(REPLACEMENTS) $$n > $(TMPFILE); \
|
||||||
|
mv $(TMPFILE) '$(DESTDIR)$(datadir)/extension/'$$(basename $$n); \
|
||||||
done
|
done
|
||||||
endif
|
|
||||||
|
|
||||||
restore_copies:
|
.PHONY: $(EXTENSION).control
|
||||||
# tests
|
$(EXTENSION).control:
|
||||||
for f in $(basename $(wildcard test/sql/*.copy)); do \
|
$(SED) $(REPLACEMENTS) $(EXTENSION).control.in > $(EXTENSION).control
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
for f in $(basename $(wildcard test/expected/*.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f test/sql/*.copy;
|
|
||||||
rm -f test/expected/*.copy;
|
|
||||||
# data
|
|
||||||
for f in $(basename $(wildcard sql/*.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f sql/*.copy;
|
|
||||||
# old_versions
|
|
||||||
for f in $(basename $(wildcard old_versions/*.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f old_versions/*.copy;
|
|
||||||
# current scripts
|
|
||||||
for f in $(basename $(wildcard *.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f *.copy;
|
|
||||||
|
|
||||||
# Replacing variables defined within test files
|
|
||||||
replace_variables: restore_copies
|
|
||||||
# tests
|
|
||||||
for f in $(sort $(wildcard test/sql/*test.sql)); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
for f in $(sort $(wildcard test/expected/*test.out)); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
# data
|
|
||||||
for f in $(wildcard sql/*.sql); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
# old_versions
|
|
||||||
for f in $(wildcard old_versions/*.sql); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
# current scripts
|
|
||||||
for f in $(wildcard *.sql); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $(EXTENSION).control;
|
|
||||||
|
|
||||||
# Install the current release into the PostgreSQL extensions directory
|
# Install the current release into the PostgreSQL extensions directory
|
||||||
deploy: release_remove_parallel_deploy
|
.PHONY: deploy
|
||||||
|
deploy: replace_variables_and_deploy $(EXTENSION).control
|
||||||
$(INSTALL_DATA) $(EXTENSION).control '$(DESTDIR)$(datadir)/extension/'
|
$(INSTALL_DATA) $(EXTENSION).control '$(DESTDIR)$(datadir)/extension/'
|
||||||
$(INSTALL_DATA) old_versions/*.sql *.sql '$(DESTDIR)$(datadir)/extension/'
|
|
||||||
|
|
||||||
install: replace_variables deploy
|
.PHONY: install
|
||||||
|
install: deploy
|
||||||
|
@echo "Install overriden"
|
||||||
|
|||||||
@@ -37,7 +37,7 @@ psql -U postgres cartodb_dev_user_fe3b850a-01c0-48f9-8a26-a82f09e9b53f_db
|
|||||||
and then:
|
and then:
|
||||||
|
|
||||||
```sql
|
```sql
|
||||||
CREATE EXTENSION cdb_dataservices_client;
|
CREATE EXTENSION cdb_dataservices_client CASCADE;
|
||||||
```
|
```
|
||||||
|
|
||||||
The extension creation in the user's db requires **superuser** privileges.
|
The extension creation in the user's db requires **superuser** privileges.
|
||||||
|
|||||||
14
client/cdb_dataservices_client--0.29.0--0.30.0.sql
Normal file
14
client/cdb_dataservices_client--0.29.0--0.30.0.sql
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
--DO NOT MODIFY THIS FILE, IT IS GENERATED AUTOMATICALLY FROM SOURCES
|
||||||
|
-- Complain if script is sourced in psql, rather than via CREATE EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION cdb_dataservices_client UPDATE TO '0.30.0'" to load this file. \quit
|
||||||
|
|
||||||
|
-- Make sure we have a sane search path to create/update the extension
|
||||||
|
SET search_path = "$user",cartodb,public,cdb_dataservices_client;
|
||||||
|
|
||||||
|
-- HERE goes your code to upgrade/downgrade
|
||||||
|
|
||||||
|
-- In 0.30.0 we removed cdb_dataservices_client.geomval and rely on postgis_raster if necessary
|
||||||
|
DO $$
|
||||||
|
BEGIN
|
||||||
|
DROP TYPE IF EXISTS cdb_dataservices_client.geomval RESTRICT;
|
||||||
|
END$$;
|
||||||
19
client/cdb_dataservices_client--0.30.0--0.29.0.sql
Normal file
19
client/cdb_dataservices_client--0.30.0--0.29.0.sql
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
--DO NOT MODIFY THIS FILE, IT IS GENERATED AUTOMATICALLY FROM SOURCES
|
||||||
|
-- Complain if script is sourced in psql, rather than via CREATE EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION cdb_dataservices_client UPDATE TO '0.29.0'" to load this file. \quit
|
||||||
|
|
||||||
|
-- Make sure we have a sane search path to create/update the extension
|
||||||
|
SET search_path = "$user",cartodb,public,cdb_dataservices_client;
|
||||||
|
|
||||||
|
-- HERE goes your code to upgrade/downgrade
|
||||||
|
|
||||||
|
-- Create cdb_dataservices_client.geomval if it doesn't exist (in postgis 3+ it only exists in postgis_raster)
|
||||||
|
DO $$
|
||||||
|
BEGIN
|
||||||
|
IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'geomval') THEN
|
||||||
|
CREATE TYPE cdb_dataservices_client.geomval AS (
|
||||||
|
geom geometry,
|
||||||
|
val double precision
|
||||||
|
);
|
||||||
|
END IF;
|
||||||
|
END$$;
|
||||||
5824
client/cdb_dataservices_client--0.30.0.sql
Normal file
5824
client/cdb_dataservices_client--0.30.0.sql
Normal file
File diff suppressed because it is too large
Load Diff
@@ -1,5 +1,5 @@
|
|||||||
comment = 'CartoDB dataservices client API extension'
|
comment = 'CartoDB dataservices client API extension'
|
||||||
default_version = '0.29.0'
|
default_version = '@@EXTVERSION@@'
|
||||||
requires = 'plproxy, cartodb'
|
requires = 'plproxy, cartodb, @@plpythonu@@, @@postgis@@'
|
||||||
superuser = true
|
superuser = true
|
||||||
schema = cdb_dataservices_client
|
schema = cdb_dataservices_client
|
||||||
0
client/old_versions/cdb_dataservices_client--0.22.0--0.23.0.sql
Executable file → Normal file
0
client/old_versions/cdb_dataservices_client--0.22.0--0.23.0.sql
Executable file → Normal file
0
client/old_versions/cdb_dataservices_client--0.23.0--0.22.0.sql
Executable file → Normal file
0
client/old_versions/cdb_dataservices_client--0.23.0--0.22.0.sql
Executable file → Normal file
@@ -18,16 +18,3 @@ $func$ LANGUAGE plpgsql;
|
|||||||
CREATE OR REPLACE FUNCTION cdb_dataservices_client.cdb_jsonb_array_casttext(jsonb) RETURNS text[] AS $f$
|
CREATE OR REPLACE FUNCTION cdb_dataservices_client.cdb_jsonb_array_casttext(jsonb) RETURNS text[] AS $f$
|
||||||
SELECT array_agg(x) || ARRAY[]::text[] FROM jsonb_array_elements_text($1) t(x);
|
SELECT array_agg(x) || ARRAY[]::text[] FROM jsonb_array_elements_text($1) t(x);
|
||||||
$f$ LANGUAGE sql IMMUTABLE;
|
$f$ LANGUAGE sql IMMUTABLE;
|
||||||
|
|
||||||
|
|
||||||
-- PG12_DEPRECATED
|
|
||||||
-- Create geomval if it doesn't exist (in postgis 3+ it only exists in postgis_raster)
|
|
||||||
DO $$
|
|
||||||
BEGIN
|
|
||||||
IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'geomval') THEN
|
|
||||||
CREATE TYPE cdb_dataservices_client.geomval AS (
|
|
||||||
geom geometry,
|
|
||||||
val double precision
|
|
||||||
);
|
|
||||||
END IF;
|
|
||||||
END$$;
|
|
||||||
@@ -1,30 +1,17 @@
|
|||||||
-- Only show warning or error messages in the tests output
|
-- Only show warning or error messages in the tests output
|
||||||
SET client_min_messages TO WARNING;
|
\set ECHO none
|
||||||
-- Install dependencies
|
|
||||||
CREATE EXTENSION postgis;
|
|
||||||
CREATE EXTENSION @@plpythonu@@;
|
|
||||||
CREATE EXTENSION cartodb;
|
|
||||||
CREATE EXTENSION plproxy;
|
|
||||||
-- Install the extension
|
|
||||||
CREATE EXTENSION cdb_dataservices_client;
|
|
||||||
-- Mock the server connection to point to this very test db
|
|
||||||
SELECT cartodb.cdb_conf_setconf('geocoder_server_config', '{"connection_str": "dbname=contrib_regression host=127.0.0.1 user=postgres"}');
|
|
||||||
cdb_conf_setconf
|
cdb_conf_setconf
|
||||||
------------------
|
------------------
|
||||||
|
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- Mock the user configuration
|
|
||||||
SELECT cartodb.cdb_conf_setconf('user_config', '{"is_organization": false, "entity_name": "test_user"}');
|
|
||||||
cdb_conf_setconf
|
cdb_conf_setconf
|
||||||
------------------
|
------------------
|
||||||
|
|
||||||
(1 row)
|
(1 row)
|
||||||
|
|
||||||
-- Mock the server schema
|
CREATE SCHEMA
|
||||||
CREATE SCHEMA cdb_dataservices_server;
|
DROP ROLE
|
||||||
-- Create a test user to check permissions
|
CREATE ROLE
|
||||||
DROP ROLE IF EXISTS test_regular_user;
|
GRANT ROLE
|
||||||
CREATE ROLE test_regular_user;
|
ALTER ROLE
|
||||||
GRANT publicuser TO test_regular_user;
|
|
||||||
ALTER ROLE test_regular_user SET search_path TO public,cartodb,cdb_dataservices_client;
|
|
||||||
|
|||||||
@@ -1,13 +1,13 @@
|
|||||||
-- Only show warning or error messages in the tests output
|
-- Only show warning or error messages in the tests output
|
||||||
|
\set ECHO none
|
||||||
|
\set QUIET on
|
||||||
SET client_min_messages TO WARNING;
|
SET client_min_messages TO WARNING;
|
||||||
-- Install dependencies
|
|
||||||
CREATE EXTENSION postgis;
|
|
||||||
CREATE EXTENSION @@plpythonu@@;
|
|
||||||
CREATE EXTENSION cartodb;
|
|
||||||
CREATE EXTENSION plproxy;
|
|
||||||
|
|
||||||
-- Install the extension
|
-- Install the extension
|
||||||
CREATE EXTENSION cdb_dataservices_client;
|
CREATE EXTENSION cdb_dataservices_client CASCADE;
|
||||||
|
|
||||||
|
\unset ECHO
|
||||||
|
\unset QUIET
|
||||||
|
|
||||||
-- Mock the server connection to point to this very test db
|
-- Mock the server connection to point to this very test db
|
||||||
SELECT cartodb.cdb_conf_setconf('geocoder_server_config', '{"connection_str": "dbname=contrib_regression host=127.0.0.1 user=postgres"}');
|
SELECT cartodb.cdb_conf_setconf('geocoder_server_config', '{"connection_str": "dbname=contrib_regression host=127.0.0.1 user=postgres"}');
|
||||||
|
|||||||
4
server/extension/.gitignore
vendored
4
server/extension/.gitignore
vendored
@@ -6,4 +6,6 @@ cdb_geocoder_server--0.1.0.sql
|
|||||||
cdb_geocoder_server--0.2.0.sql
|
cdb_geocoder_server--0.2.0.sql
|
||||||
cdb_geocoder_server--0.3.0.sql
|
cdb_geocoder_server--0.3.0.sql
|
||||||
cdb_geocoder_server--0.4.0.sql
|
cdb_geocoder_server--0.4.0.sql
|
||||||
cdb_geocoder_server--0.5.0.sql
|
cdb_geocoder_server--0.5.0.sql
|
||||||
|
cdb_dataservices_server.control
|
||||||
|
./test/sql/366_empty_table_test.sql
|
||||||
|
|||||||
@@ -1,17 +1,32 @@
|
|||||||
# Makefile to generate the extension out of separate sql source files.
|
# Makefile to generate the extension out of separate sql source files.
|
||||||
# Once a version is released, it is not meant to be changed. E.g: once version 0.0.1 is out, it SHALL NOT be changed.
|
# Once a version is released, it is not meant to be changed. E.g: once version 0.0.1 is out, it SHALL NOT be changed.
|
||||||
EXTENSION = cdb_dataservices_server
|
EXTENSION = cdb_dataservices_server
|
||||||
EXTVERSION = $(shell grep default_version $(EXTENSION).control | sed -e "s/default_version[[:space:]]*=[[:space:]]*'\([^']*\)'/\1/")
|
EXTVERSION = 0.39.0
|
||||||
|
|
||||||
# The new version to be generated from templates
|
# The new version to be generated from templates
|
||||||
SED = sed
|
SED ?= sed
|
||||||
ERB = erb
|
ERB ?= erb
|
||||||
NEW_EXTENSION_ARTIFACT = $(EXTENSION)--$(EXTVERSION).sql
|
AWK ?= awk
|
||||||
AWK = awk
|
PG_CONFIG ?= pg_config
|
||||||
|
|
||||||
# Parallel support macros
|
# Parallel support macros
|
||||||
PG_CONFIG = pg_config
|
PG_CONFIG ?= pg_config
|
||||||
PG_PARALLEL := $(shell $(PG_CONFIG) --version | ($(AWK) '{$$2*=1000; if ($$2 >= 9600) print 1; else print 0;}' 2> /dev/null || echo 0))
|
PG_PARALLEL := $(shell $(PG_CONFIG) --version | ($(AWK) '{$$2*=1000; if ($$2 >= 9600) print 1; else print 0;}' 2> /dev/null || echo 0))
|
||||||
|
|
||||||
|
# PG12 compatibility
|
||||||
|
PG_VERSION := $(shell $(PG_CONFIG) --version | $(AWK) '{split($$2,a,"."); print a[1]}')
|
||||||
|
PG_12_GE := $(shell [ $(PG_VERSION) -ge 12 ] && echo true)
|
||||||
|
PLPYTHONU := plpythonu
|
||||||
|
POSTGIS := postgis
|
||||||
|
ifeq ($(PG_12_GE), true)
|
||||||
|
PLPYTHONU := plpython3u
|
||||||
|
POSTGIS := postgis, postgis_raster
|
||||||
|
endif
|
||||||
|
|
||||||
|
REPLACEMENTS = -e 's/@@EXTVERSION@@/$(EXTVERSION)/g' -e 's/@@plpythonu@@/$(PLPYTHONU)/g' -e 's/@@postgis@@/$(POSTGIS)/g'
|
||||||
|
REPLACEMENTS_TEST_REVERSE = -e 's/$(PLPYTHONU)/@@plpythonu@@/g'
|
||||||
|
NEW_EXTENSION_ARTIFACT = $(EXTENSION)--$(EXTVERSION).sql
|
||||||
|
|
||||||
REGRESS = $(notdir $(basename $(sort $(wildcard test/sql/*test.sql))))
|
REGRESS = $(notdir $(basename $(sort $(wildcard test/sql/*test.sql))))
|
||||||
REGRESS_EXPEC = $(notdir $(basename $(sort $(wildcard test/expected/*test.out))))
|
REGRESS_EXPEC = $(notdir $(basename $(sort $(wildcard test/expected/*test.out))))
|
||||||
TEST_DIR = test
|
TEST_DIR = test
|
||||||
@@ -29,52 +44,35 @@ SOURCES_DATA_DIR = sql/
|
|||||||
SOURCES_DATA = $(wildcard sql/*.sql)
|
SOURCES_DATA = $(wildcard sql/*.sql)
|
||||||
|
|
||||||
# postgres build stuff
|
# postgres build stuff
|
||||||
PG_CONFIG = pg_config
|
|
||||||
|
# The targets listed under REGRESS_PREP are executed before regress
|
||||||
|
PYTHON_TESTS = ./test/sql/366_empty_table_test.sql
|
||||||
|
REGRESS_PREP = $(PYTHON_TESTS)
|
||||||
|
|
||||||
|
./test/sql/366_empty_table_test.sql: ./test/sql/366_empty_table_test.sql.template
|
||||||
|
$(SED) $(REPLACEMENTS) $@.template > $@
|
||||||
|
|
||||||
PGXS := $(shell $(PG_CONFIG) --pgxs)
|
PGXS := $(shell $(PG_CONFIG) --pgxs)
|
||||||
include $(PGXS)
|
include $(PGXS)
|
||||||
|
|
||||||
# PG12 compatibility
|
|
||||||
PG_VERSION := $(shell $(PG_CONFIG) --version | $(AWK) '{split($$2,a,"."); print a[1]}')
|
|
||||||
PG_12_GE := $(shell [ $(PG_VERSION) -ge 12 ] && echo true)
|
|
||||||
PLPYTHONU := plpythonu
|
|
||||||
ifeq ($(PG_12_GE), true)
|
|
||||||
PLPYTHONU := plpython3u
|
|
||||||
endif
|
|
||||||
|
|
||||||
REPLACEMENTS = -e 's/@@plpythonu@@/$(PLPYTHONU)/g'
|
|
||||||
ifneq ($(NEW_VERSION),)
|
|
||||||
REPLACEMENTS += -e 's/$(EXTVERSION)/$(NEW_VERSION)/g'
|
|
||||||
endif
|
|
||||||
|
|
||||||
$(NEW_EXTENSION_ARTIFACT): $(SOURCES_DATA)
|
$(NEW_EXTENSION_ARTIFACT): $(SOURCES_DATA)
|
||||||
rm -f $@
|
rm -f $@
|
||||||
cat $(SOURCES_DATA_DIR)/*.sql >> $@
|
cat $(SOURCES_DATA_DIR)/*.sql >> $@
|
||||||
ifeq ($(PG_PARALLEL), 0)
|
|
||||||
# Remove PARALLEL in aggregates and functions
|
|
||||||
$(eval TMPFILE := $(shell mktemp /tmp/$(basename $0).XXXXXXXX))
|
|
||||||
$(SED) -e 's/PARALLEL \= [A-Z]*,/''/g' \
|
|
||||||
-e 's/PARALLEL [A-Z]*/''/g' $@ > $(TMPFILE)
|
|
||||||
mv $(TMPFILE) $@
|
|
||||||
endif
|
|
||||||
|
|
||||||
# $(EXTENSION).control: $(EXTENSION).control.in Makefile
|
|
||||||
# $(SED) $(REPLACEMENTS) $< > $@
|
|
||||||
|
|
||||||
.PHONY: all
|
.PHONY: all
|
||||||
all: $(DATA)
|
all: $(DATA)
|
||||||
|
|
||||||
.PHONY: release
|
.PHONY: release
|
||||||
release: $(EXTENSION).control $(SOURCES_DATA)
|
release: $(SOURCES_DATA)
|
||||||
test -n "$(NEW_VERSION)" # $$NEW_VERSION VARIABLE MISSING. Eg. make release NEW_VERSION=0.x.0
|
test -n "$(NEW_VERSION)" # $$NEW_VERSION VARIABLE MISSING. Eg. make release NEW_VERSION=0.x.0
|
||||||
for f in $(wildcard *.sql); do \
|
git mv *.sql old_versions
|
||||||
git mv $${f} old_versions/$${f}; \
|
|
||||||
done
|
|
||||||
$(SED) -i 's/$(EXTVERSION)/$(NEW_VERSION)/g' $(EXTENSION).control
|
|
||||||
git add $(EXTENSION).control
|
|
||||||
cat $(SOURCES_DATA_DIR)/*.sql > $(EXTENSION)--$(NEW_VERSION).sql
|
cat $(SOURCES_DATA_DIR)/*.sql > $(EXTENSION)--$(NEW_VERSION).sql
|
||||||
$(ERB) version=$(NEW_VERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql
|
$(ERB) version=$(NEW_VERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql
|
||||||
$(ERB) version=$(EXTVERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql
|
$(ERB) version=$(EXTVERSION) upgrade_downgrade_template.erb > $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql
|
||||||
git add $(EXTENSION)--$(NEW_VERSION).sql
|
git add $(EXTENSION)--$(NEW_VERSION).sql
|
||||||
|
$(SED) -i -e 's/^EXTVERSION =.*/EXTVERSION = $(NEW_VERSION)/g' Makefile
|
||||||
|
git add Makefile
|
||||||
@echo
|
@echo
|
||||||
@echo "Please review the file $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql.in and add any code needed to upgrade $(EXTVERSION) to $(NEW_VERSION)"
|
@echo "Please review the file $(EXTENSION)--$(EXTVERSION)--$(NEW_VERSION).sql.in and add any code needed to upgrade $(EXTVERSION) to $(NEW_VERSION)"
|
||||||
@echo "Please review the file $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql.in and add any code needed to downgrade $(NEW_VERSION) to $(EXTVERSION)"
|
@echo "Please review the file $(EXTENSION)--$(NEW_VERSION)--$(EXTVERSION).sql.in and add any code needed to downgrade $(NEW_VERSION) to $(EXTVERSION)"
|
||||||
@@ -84,78 +82,32 @@ release: $(EXTENSION).control $(SOURCES_DATA)
|
|||||||
.PHONY: devclean
|
.PHONY: devclean
|
||||||
devclean:
|
devclean:
|
||||||
rm -f $(NEW_EXTENSION_ARTIFACT)
|
rm -f $(NEW_EXTENSION_ARTIFACT)
|
||||||
|
rm -f $(PYTHON_TESTS)
|
||||||
|
|
||||||
clean: restore_copies
|
# Replace variables (and PARALLEL tags if necessary) and deploy files
|
||||||
|
.PHONY: replace_variables_and_deploy
|
||||||
# If needed remove PARALLEL tags from the release files
|
replace_variables_and_deploy: $(NEW_EXTENSION_ARTIFACT)
|
||||||
release_remove_parallel_deploy:
|
mkdir -p '$(DESTDIR)$(datadir)/extension/'; \
|
||||||
ifeq ($(PG_PARALLEL), 0)
|
|
||||||
for n in $(wildcard old_versions/*.sql *.sql); do \
|
for n in $(wildcard old_versions/*.sql *.sql); do \
|
||||||
$(eval TMPFILE := $(shell mktemp /tmp/XXXXXXXXXX)) \
|
$(eval TMPFILE := $(shell mktemp /tmp/XXXXXXXXXX)) \
|
||||||
$(SED) -e 's/PARALLEL \= [A-Z]*,/''/g' -e 's/PARALLEL [A-Z]*/''/g' $$n > $(TMPFILE); \
|
if [ "$(PG_PARALLEL)" -eq "0" ]; then \
|
||||||
mv $(TMPFILE) $$n; \
|
$(SED) -e 's/PARALLEL \= [A-Z]*,/''/g' -e 's/PARALLEL [A-Z]*/''/g' $$n > $(TMPFILE); \
|
||||||
|
mv $(TMPFILE) $$n; \
|
||||||
|
fi; \
|
||||||
|
$(SED) $(REPLACEMENTS) $$n > $(TMPFILE); \
|
||||||
|
mv $(TMPFILE) '$(DESTDIR)$(datadir)/extension/'$$(basename $$n); \
|
||||||
done
|
done
|
||||||
endif
|
|
||||||
|
|
||||||
|
.PHONY: $(EXTENSION).control
|
||||||
|
$(EXTENSION).control:
|
||||||
|
$(SED) $(REPLACEMENTS) $(EXTENSION).control.in > $(EXTENSION).control
|
||||||
|
|
||||||
# Install the current release into the PostgreSQL extensions directory
|
# Install the current release into the PostgreSQL extensions directory
|
||||||
deploy: release_remove_parallel_deploy
|
.PHONY: deploy
|
||||||
|
deploy: replace_variables_and_deploy $(EXTENSION).control
|
||||||
$(INSTALL_DATA) $(EXTENSION).control '$(DESTDIR)$(datadir)/extension/'
|
$(INSTALL_DATA) $(EXTENSION).control '$(DESTDIR)$(datadir)/extension/'
|
||||||
$(INSTALL_DATA) old_versions/*.sql *.sql '$(DESTDIR)$(datadir)/extension/'
|
|
||||||
|
|
||||||
restore_copies:
|
.PHONY: install
|
||||||
# tests
|
install: deploy
|
||||||
for f in $(basename $(wildcard test/sql/*.copy)); do \
|
@echo "Install overriden"
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
for f in $(basename $(wildcard test/expected/*.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f test/sql/*.copy;
|
|
||||||
rm -f test/expected/*.copy;
|
|
||||||
# data
|
|
||||||
for f in $(basename $(wildcard sql/*.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f sql/*.copy;
|
|
||||||
# old_versions
|
|
||||||
for f in $(basename $(wildcard old_versions/*.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f old_versions/*.copy;
|
|
||||||
# current scripts
|
|
||||||
for f in $(basename $(wildcard *.copy)); do \
|
|
||||||
cat $${f}.copy > $${f}; \
|
|
||||||
done
|
|
||||||
rm -f *.copy;
|
|
||||||
|
|
||||||
|
|
||||||
# %.sql:
|
|
||||||
# $(SED) $(REPLACEMENTS) $< > $@
|
|
||||||
|
|
||||||
# Replacing variables defined within test files
|
|
||||||
replace_variables: restore_copies
|
|
||||||
# tests
|
|
||||||
for f in $(sort $(wildcard test/sql/*test.sql)); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
for f in $(sort $(wildcard test/expected/*test.out)); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
# data
|
|
||||||
for f in $(SOURCES_DATA); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
# old_versions
|
|
||||||
for f in $(wildcard old_versions/*.sql); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
# current scripts
|
|
||||||
for f in $(wildcard *.sql); do \
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $${f}; \
|
|
||||||
done
|
|
||||||
sed --in-place=.copy -e 's/@@plpythonu@@/$(PLPYTHONU)/g' $(EXTENSION).control;
|
|
||||||
|
|
||||||
install: replace_variables deploy
|
|
||||||
|
|
||||||
reinstall: install
|
|
||||||
psql -U postgres -d dataservices_db -c "drop extension if exists cdb_dataservices_server; create extension cdb_dataservices_server;"
|
|
||||||
|
|||||||
11
server/extension/cdb_dataservices_server--0.38.0--0.39.0.sql
Normal file
11
server/extension/cdb_dataservices_server--0.38.0--0.39.0.sql
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
--DO NOT MODIFY THIS FILE, IT IS GENERATED AUTOMATICALLY FROM SOURCES
|
||||||
|
-- Complain if script is sourced in psql, rather than via CREATE EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION cdb_dataservices_server UPDATE TO '0.39.0'" to load this file. \quit
|
||||||
|
|
||||||
|
-- HERE goes your code to upgrade/downgrade
|
||||||
|
|
||||||
|
-- In 0.39.0 we removed cdb_dataservices_client.geomval and rely on postgis_raster if necessary
|
||||||
|
DO $$
|
||||||
|
BEGIN
|
||||||
|
DROP TYPE IF EXISTS cdb_dataservices_server.geomval RESTRICT;
|
||||||
|
END$$;
|
||||||
@@ -1,4 +1,9 @@
|
|||||||
-- PG12_DEPRECATED
|
--DO NOT MODIFY THIS FILE, IT IS GENERATED AUTOMATICALLY FROM SOURCES
|
||||||
|
-- Complain if script is sourced in psql, rather than via CREATE EXTENSION
|
||||||
|
\echo Use "ALTER EXTENSION cdb_dataservices_server UPDATE TO '0.38.0'" to load this file. \quit
|
||||||
|
|
||||||
|
-- HERE goes your code to upgrade/downgrade
|
||||||
|
|
||||||
-- Create geomval if it doesn't exist (in postgis 3+ it only exists in postgis_raster)
|
-- Create geomval if it doesn't exist (in postgis 3+ it only exists in postgis_raster)
|
||||||
DO $$
|
DO $$
|
||||||
BEGIN
|
BEGIN
|
||||||
@@ -8,4 +13,4 @@ BEGIN
|
|||||||
val double precision
|
val double precision
|
||||||
);
|
);
|
||||||
END IF;
|
END IF;
|
||||||
END$$;
|
END$$;
|
||||||
3886
server/extension/cdb_dataservices_server--0.39.0.sql
Normal file
3886
server/extension/cdb_dataservices_server--0.39.0.sql
Normal file
File diff suppressed because it is too large
Load Diff
@@ -1,5 +1,5 @@
|
|||||||
comment = 'CartoDB dataservices server extension'
|
comment = 'CartoDB dataservices server extension'
|
||||||
default_version = '0.38.0'
|
default_version = '@@EXTVERSION@@'
|
||||||
requires = '@@plpythonu@@, plproxy, postgis, cdb_geocoder'
|
requires = '@@plpythonu@@, plproxy, @@postgis@@, cdb_geocoder'
|
||||||
superuser = true
|
superuser = true
|
||||||
schema = cdb_dataservices_server
|
schema = cdb_dataservices_server
|
||||||
@@ -1,13 +1,9 @@
|
|||||||
-- Only show warning or error messages in the tests output
|
-- Only show warning or error messages in the tests output
|
||||||
|
\set QUIET on
|
||||||
SET client_min_messages TO WARNING;
|
SET client_min_messages TO WARNING;
|
||||||
-- Install dependencies
|
|
||||||
CREATE EXTENSION postgis;
|
|
||||||
CREATE EXTENSION @@plpythonu@@;
|
|
||||||
CREATE EXTENSION plproxy;
|
|
||||||
CREATE EXTENSION cartodb;
|
|
||||||
CREATE EXTENSION cdb_geocoder;
|
|
||||||
-- Install the extension
|
-- Install the extension
|
||||||
CREATE EXTENSION cdb_dataservices_server;
|
CREATE EXTENSION cdb_dataservices_server CASCADE;
|
||||||
|
\unset QUIET
|
||||||
-- Mock the redis server connection to point to this very test db
|
-- Mock the redis server connection to point to this very test db
|
||||||
SELECT cartodb.cdb_conf_setconf('redis_metrics_config', '{"redis_host": "localhost", "redis_port": 6379, "timeout": 0.1, "redis_db": 5}');
|
SELECT cartodb.cdb_conf_setconf('redis_metrics_config', '{"redis_host": "localhost", "redis_port": 6379, "timeout": 0.1, "redis_db": 5}');
|
||||||
cdb_conf_setconf
|
cdb_conf_setconf
|
||||||
@@ -71,6 +67,7 @@ BEGIN
|
|||||||
END
|
END
|
||||||
$$
|
$$
|
||||||
LANGUAGE plpgsql;
|
LANGUAGE plpgsql;
|
||||||
|
CREATE FUNCTION
|
||||||
-- Set user quota
|
-- Set user quota
|
||||||
SELECT cartodb.CDB_SetUserQuotaInBytes(0);
|
SELECT cartodb.CDB_SetUserQuotaInBytes(0);
|
||||||
cdb_setuserquotainbytes
|
cdb_setuserquotainbytes
|
||||||
|
|||||||
@@ -1,14 +1,10 @@
|
|||||||
-- Only show warning or error messages in the tests output
|
-- Only show warning or error messages in the tests output
|
||||||
|
\set QUIET on
|
||||||
SET client_min_messages TO WARNING;
|
SET client_min_messages TO WARNING;
|
||||||
-- Install dependencies
|
|
||||||
CREATE EXTENSION postgis;
|
|
||||||
CREATE EXTENSION @@plpythonu@@;
|
|
||||||
CREATE EXTENSION plproxy;
|
|
||||||
CREATE EXTENSION cartodb;
|
|
||||||
CREATE EXTENSION cdb_geocoder;
|
|
||||||
|
|
||||||
-- Install the extension
|
-- Install the extension
|
||||||
CREATE EXTENSION cdb_dataservices_server;
|
CREATE EXTENSION cdb_dataservices_server CASCADE;
|
||||||
|
\unset QUIET
|
||||||
|
|
||||||
-- Mock the redis server connection to point to this very test db
|
-- Mock the redis server connection to point to this very test db
|
||||||
SELECT cartodb.cdb_conf_setconf('redis_metrics_config', '{"redis_host": "localhost", "redis_port": 6379, "timeout": 0.1, "redis_db": 5}');
|
SELECT cartodb.cdb_conf_setconf('redis_metrics_config', '{"redis_host": "localhost", "redis_port": 6379, "timeout": 0.1, "redis_db": 5}');
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ HereJobStatus = namedtuple('HereJobStatus', 'total_count processed_count status'
|
|||||||
class HereMapsBulkGeocoder(HereMapsGeocoder, StreetPointBulkGeocoder):
|
class HereMapsBulkGeocoder(HereMapsGeocoder, StreetPointBulkGeocoder):
|
||||||
MAX_BATCH_SIZE = 1000000 # From the docs
|
MAX_BATCH_SIZE = 1000000 # From the docs
|
||||||
MIN_BATCHED_SEARCH = 100 # Under this, serial will be used
|
MIN_BATCHED_SEARCH = 100 # Under this, serial will be used
|
||||||
BATCH_URL = 'https://batch.geocoder.cit.api.here.com/6.2/jobs'
|
BATCH_URL = 'https://batch.geocoder.api.here.com/6.2/jobs'
|
||||||
# https://developer.here.com/documentation/batch-geocoder/topics/read-batch-request-output.html
|
# https://developer.here.com/documentation/batch-geocoder/topics/read-batch-request-output.html
|
||||||
META_COLS = ['relevance', 'matchType', 'matchCode', 'matchLevel', 'matchQualityStreet']
|
META_COLS = ['relevance', 'matchType', 'matchCode', 'matchLevel', 'matchQualityStreet']
|
||||||
MAX_STALLED_RETRIES = 100
|
MAX_STALLED_RETRIES = 100
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ from setuptools import setup, find_packages
|
|||||||
setup(
|
setup(
|
||||||
name='cartodb_services',
|
name='cartodb_services',
|
||||||
|
|
||||||
version='0.23.2',
|
version='0.23.3',
|
||||||
|
|
||||||
description='CartoDB Services API Python Library',
|
description='CartoDB Services API Python Library',
|
||||||
|
|
||||||
|
|||||||
@@ -280,18 +280,18 @@ class TestBulkStreetFunctions(TestStreetFunctionsSetUp):
|
|||||||
def test_templating_geocoding(self):
|
def test_templating_geocoding(self):
|
||||||
query = "SELECT cartodb_id, st_x(the_geom), st_y(the_geom) from " \
|
query = "SELECT cartodb_id, st_x(the_geom), st_y(the_geom) from " \
|
||||||
"cdb_dataservices_client.cdb_bulk_geocode_street_point(" \
|
"cdb_dataservices_client.cdb_bulk_geocode_street_point(" \
|
||||||
"'select 1 as cartodb_id, ''Logroño'' as city', " \
|
"'select 1 as cartodb_id, ''Valladolid'' as city', " \
|
||||||
"'city || '', '' || ''Spain''') " \
|
"'city || '', '' || ''Spain''') " \
|
||||||
"UNION " \
|
"UNION " \
|
||||||
"SELECT cartodb_id, st_x(the_geom), st_y(the_geom) from " \
|
"SELECT cartodb_id, st_x(the_geom), st_y(the_geom) from " \
|
||||||
"cdb_dataservices_client.cdb_bulk_geocode_street_point(" \
|
"cdb_dataservices_client.cdb_bulk_geocode_street_point(" \
|
||||||
"'select 2 as cartodb_id, ''Logroño'' as city', " \
|
"'select 2 as cartodb_id, ''Valladolid'' as city', " \
|
||||||
"'city || '', '' || ''Argentina''')"
|
"'city || '', '' || ''Mexico''')"
|
||||||
response = self._run_authenticated(query)
|
response = self._run_authenticated(query)
|
||||||
|
|
||||||
points_by_cartodb_id = {
|
points_by_cartodb_id = {
|
||||||
1: self.fixture_points['Logroño, Spain'],
|
1: self.fixture_points['Valladolid, Spain'],
|
||||||
2: self.fixture_points['Logroño, Argentina']
|
2: self.fixture_points['Valladolid, Mexico']
|
||||||
}
|
}
|
||||||
self.assert_close_points(self._x_y_by_cartodb_id(response), points_by_cartodb_id)
|
self.assert_close_points(self._x_y_by_cartodb_id(response), points_by_cartodb_id)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user