Use containers.Map over struct for name field flexibility, allow dashes in schema names, escape schema name in creation, update reverse proxy, bump version.

Author: guzman-raphael

+dj/+internal/GeneralRelvar.m

@@ -951,7 +951,7 @@ case isa(cond, 'dj.internal.GeneralRelvar')
             for j = 1:length(data)
                 if ~isempty(data(j).(attr(i).name))
                     uuid = reshape(lower(dec2hex(data(j).(attr(i).name))).',1,[]);
-                    data(j).(attr(i).name) = connection.schemas.(...
+                    data(j).(attr(i).name) = connection.schemas(...
                         attr(i).database).external.table(...
                         attr(i).store).download_buffer(uuid);
                 end

+dj/Connection.m

@@ -41,12 +41,12 @@
             end
             self.foreignKeys  = struct([]);
             self.packages = containers.Map;
-            self.schemas = struct();
+            self.schemas = containers.Map;
         end
 
 
         function register(self, schema)
-            self.schemas.(schema.dbname) = schema;
+            self.schemas(schema.dbname) = schema;
         end
 
         function addPackage(self, dbname, package)

+dj/createSchema.m

@@ -14,7 +14,7 @@ function createSchema(package, parentdir, db)
 
     if ~dbname
         disp 'No database name entered. Quitting.'
-    elseif isempty(regexp(dbname,'^[a-z][a-z0-9_]*$','once'))
+    elseif isempty(regexp(dbname,'^[a-z][a-z0-9_\-]*$','once'))
         error(['Invalid database name. Begin with a letter, only lowercase alphanumerical and ' ...
             'underscores.'])
     else
@@ -26,7 +26,7 @@ function createSchema(package, parentdir, db)
         if ~isempty(s.schema_name)
             disp 'database already exists'
         else
-            query(dj.conn, sprintf('create schema %s',dbname))
+            query(dj.conn, sprintf('CREATE SCHEMA `%s`',dbname))
             disp 'database created'
         end
 

+dj/version.m

@@ -1,7 +1,7 @@
 function varargout = version
 % report DataJoint version
 
-v = struct('major', 3, 'minor', 5, 'bugfix', 0);
+v = struct('major', 3, 'minor', 5, 'bugfix', 1);
 
 if nargout
     varargout{1}=v;

LNX-docker-compose.yaml

@@ -1,4 +1,4 @@
-# docker-compose -f LNX-docker-compose.yaml --env-file LNX.env up --exit-code-from app --build
+# docker compose -f LNX-docker-compose.yaml --env-file LNX.env up --exit-code-from app --build
 version: '2.2'
 x-net: &net
   networks:
@@ -29,7 +29,7 @@ services:
       interval: 1s
   fakeservices.datajoint.io:
     <<: *net
-    image: datajoint/nginx:v0.1.1
+    image: datajoint/nginx:v0.2.4
     environment:
     - ADD_db_TYPE=DATABASE
     - ADD_db_ENDPOINT=db:3306

local-docker-compose.yaml

@@ -1,4 +1,4 @@
-# docker-compose -f local-docker-compose.yaml --env-file LNX.env up --build
+# docker compose -f local-docker-compose.yaml --env-file LNX.env up --build
 version: '2.4'
 x-net: &net
   networks:
@@ -34,7 +34,7 @@ services:
       interval: 1s
   fakeservices.datajoint.io:
     <<: *net
-    image: datajoint/nginx:v0.1.1
+    image: datajoint/nginx:v0.2.4
     environment:
     - ADD_db_TYPE=DATABASE
     - ADD_db_ENDPOINT=db:3306

tests/Prep.m

@@ -115,8 +115,8 @@ function dispose(testCase)
             curr_conn.query('SET FOREIGN_KEY_CHECKS=0;');
             res = curr_conn.query(['SHOW DATABASES LIKE "' testCase.PREFIX '_%";']);
             for i = 1:length(res.(['Database (' testCase.PREFIX '_%)']))
-                curr_conn.query(['DROP DATABASE ' ...
-                    res.(['Database (' testCase.PREFIX '_%)']){i} ';']);
+                curr_conn.query(['DROP DATABASE `' ...
+                    res.(['Database (' testCase.PREFIX '_%)']){i} '`;']);
             end
             curr_conn.query('SET FOREIGN_KEY_CHECKS=1;');
 

tests/TestSchema.m

@@ -100,8 +100,8 @@ function TestSchema_testNew(testCase)
             % setup
             dj.config.restore;
             dj.config('safemode', false);
-            dj.new('new.Student', 'M', pwd , 'djtest_new');
-            rmdir('+new', 's');
+            dj.new('new_space.Student', 'M', pwd , 'djtest_new-space');
+            rmdir('+new_space', 's');
         end
         function TestSchema_testVirtual(testCase)
             st = dbstack;