Add blueprints for manipulating database from sql statements

db/create.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeCreateStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/db.go

@@ -0,0 +1,72 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"io"
+
+	"github.com/abcum/surreal/sql"
+)
+
+func Execute(query *sql.Query, err error) (interface{}, error) {
+
+	for _, s := range query.Statements {
+
+		switch s.(type) {
+
+		case *sql.SelectStatement:
+			return executeSelectStatement(s), err
+		case *sql.CreateStatement:
+			return executeCreateStatement(s), err
+		case *sql.UpdateStatement:
+			return executeUpdateStatement(s), err
+		case *sql.ModifyStatement:
+			return executeModifyStatement(s), err
+		case *sql.DeleteStatement:
+			return executeDeleteStatement(s), err
+		case *sql.RelateStatement:
+			return executeRelateStatement(s), err
+		case *sql.RecordStatement:
+			return executeRecordStatement(s), err
+
+		case *sql.DefineViewStatement:
+			return executeDefineStatement(s), err
+		case *sql.ResyncViewStatement:
+			return executeResyncStatement(s), err
+		case *sql.RemoveViewStatement:
+			return executeRemoveStatement(s), err
+
+		case *sql.DefineIndexStatement:
+			return executeDefineStatement(s), err
+		case *sql.ResyncIndexStatement:
+			return executeResyncStatement(s), err
+		case *sql.RemoveIndexStatement:
+			return executeRemoveStatement(s), err
+
+		}
+
+	}
+
+	return query, err
+
+}
+
+func ExecuteString(input string) (interface{}, error) {
+	return Execute(sql.Parse(input))
+}
+
+func ExecuteBuffer(input io.Reader) (interface{}, error) {
+	return Execute(sql.NewParser(input).Parse())
+}

db/define.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeDefineStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/delete.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeDeleteStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/modify.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeModifyStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/record.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeRecordStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/relate.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeRelateStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/remove.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeRemoveStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/resync.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeResyncStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/select.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeSelectStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

db/update.go

@@ -0,0 +1,23 @@
+// Copyright © 2016 Abcum Ltd
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package db
+
+import (
+	"github.com/abcum/surreal/sql"
+)
+
+func executeUpdateStatement(stmt sql.Statement) interface{} {
+	return stmt
+}

server/crud.go

@@ -15,13 +15,13 @@
 package server
 
 import (
-	"github.com/abcum/surreal/sql"
+	"github.com/abcum/surreal/db"
 	"github.com/labstack/echo"
 )
 
 func crud(c *echo.Context) error {
 
-	s, e := sql.NewParser(c.Request().Body).Parse()
+	s, e := db.ExecuteBuffer(c.Request().Body)
 
 	if e == nil {
 		return c.JSON(200, show(s))

server/sock.go

@@ -15,7 +15,7 @@
 package server
 
 import (
-	"github.com/abcum/surreal/sql"
+	"github.com/abcum/surreal/db"
 	"github.com/labstack/echo"
 	"golang.org/x/net/websocket"
 )
@@ -32,7 +32,7 @@ func sock(c *echo.Context) error {
 			break
 		}
 
-		s, e := sql.Parse(msg)
+		s, e := db.ExecuteString(msg)
 
 		if e == nil {
 			if err := websocket.Message.Send(ws, encode(show(s))); err != nil {