barak/cayley
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Destutter mql

Browse source
This commit is contained in:
kortschak 2014-06-28 12:58:03 +09:30
parent 3a673a333c
commit 913d567ae1
5 changed files with 18 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

2
db/repl.go
View file

@ -66,7 +66,7 @@ func Repl(ts graph.TripleStore, queryLanguage string, cfg *config.Config) {
case "sexp": case "sexp":
ses = sexp.NewSexpSession(ts) ses = sexp.NewSexpSession(ts)
case "mql": case "mql":
ses = mql.NewMqlSession(ts) ses = mql.NewSession(ts)
case "gremlin": case "gremlin":
fallthrough fallthrough
default: default:

4
http/query.go
View file

@ -73,7 +73,7 @@ func (api *Api) ServeV1Query(w http.ResponseWriter, r *http.Request, params http
case "gremlin": case "gremlin":
ses = gremlin.NewSession(api.ts, api.config.GremlinTimeout, false) ses = gremlin.NewSession(api.ts, api.config.GremlinTimeout, false)
case "mql": case "mql":
ses = mql.NewMqlSession(api.ts) ses = mql.NewSession(api.ts)
default: default:
return FormatJson400(w, "Need a query language.") return FormatJson400(w, "Need a query language.")
} }
@ -122,7 +122,7 @@ func (api *Api) ServeV1Shape(w http.ResponseWriter, r *http.Request, params http
case "gremlin": case "gremlin":
ses = gremlin.NewSession(api.ts, api.config.GremlinTimeout, false) ses = gremlin.NewSession(api.ts, api.config.GremlinTimeout, false)
case "mql": case "mql":
ses = mql.NewMqlSession(api.ts) ses = mql.NewSession(api.ts)
default: default:
return FormatJson400(w, "Need a query language.") return FormatJson400(w, "Need a query language.")
} }

4
query/mql/functional_test.go
View file

@ -35,9 +35,9 @@ import (
// +---+ // +---+
// //
func buildTripleStore() *MqlSession { func buildTripleStore() *Session {
ts := memstore.MakeTestingMemstore() ts := memstore.MakeTestingMemstore()
return NewMqlSession(ts) return NewSession(ts)
} }
func compareJsonInterfaces(actual interface{}, expected interface{}, path MqlPath, t *testing.T) { func compareJsonInterfaces(actual interface{}, expected interface{}, path MqlPath, t *testing.T) {

4
query/mql/query.go
View file

@ -25,7 +25,7 @@ type MqlPath string
type MqlResultPath string type MqlResultPath string
type MqlQuery struct { type MqlQuery struct {
ses *MqlSession ses *Session
it graph.Iterator it graph.Iterator
isRepeated map[MqlPath]bool isRepeated map[MqlPath]bool
queryStructure map[MqlPath]map[string]interface{} queryStructure map[MqlPath]map[string]interface{}
@ -100,7 +100,7 @@ func (p MqlPath) ToResultPathFromMap(resultMap map[MqlPath]string) MqlResultPath
return output return output
} }
func NewMqlQuery(ses *MqlSession) *MqlQuery { func NewMqlQuery(ses *Session) *MqlQuery {
var q MqlQuery var q MqlQuery
q.ses = ses q.ses = ses
q.results = make([]interface{}, 0) q.results = make([]interface{}, 0)

22
query/mql/session.go
View file

@ -24,23 +24,23 @@ import (
"github.com/google/cayley/graph" "github.com/google/cayley/graph"
) )
type MqlSession struct { type Session struct {
ts graph.TripleStore ts graph.TripleStore
currentQuery *MqlQuery currentQuery *MqlQuery
debug bool debug bool
} }
func NewMqlSession(ts graph.TripleStore) *MqlSession { func NewSession(ts graph.TripleStore) *Session {
var m MqlSession var m Session
m.ts = ts m.ts = ts
return &m return &m
} }
func (m *MqlSession) ToggleDebug() { func (m *Session) ToggleDebug() {
m.debug = !m.debug m.debug = !m.debug
} }
func (m *MqlSession) GetQuery(input string, output_struct chan map[string]interface{}) { func (m *Session) GetQuery(input string, output_struct chan map[string]interface{}) {
defer close(output_struct) defer close(output_struct)
var mqlQuery interface{} var mqlQuery interface{}
err := json.Unmarshal([]byte(input), &mqlQuery) err := json.Unmarshal([]byte(input), &mqlQuery)
@ -61,7 +61,7 @@ func (m *MqlSession) GetQuery(input string, output_struct chan map[string]interf
output_struct <- output output_struct <- output
} }
func (m *MqlSession) InputParses(input string) (graph.ParseResult, error) { func (m *Session) InputParses(input string) (graph.ParseResult, error) {
var x interface{} var x interface{}
err := json.Unmarshal([]byte(input), &x) err := json.Unmarshal([]byte(input), &x)
if err != nil { if err != nil {
@ -70,7 +70,7 @@ func (m *MqlSession) InputParses(input string) (graph.ParseResult, error) {
return graph.Parsed, nil return graph.Parsed, nil
} }
func (m *MqlSession) ExecInput(input string, c chan interface{}, limit int) { func (m *Session) ExecInput(input string, c chan interface{}, limit int) {
defer close(c) defer close(c)
var mqlQuery interface{} var mqlQuery interface{}
err := json.Unmarshal([]byte(input), &mqlQuery) err := json.Unmarshal([]byte(input), &mqlQuery)
@ -102,7 +102,7 @@ func (m *MqlSession) ExecInput(input string, c chan interface{}, limit int) {
} }
} }
func (m *MqlSession) ToText(result interface{}) string { func (m *Session) ToText(result interface{}) string {
tags := *(result.(*map[string]graph.TSVal)) tags := *(result.(*map[string]graph.TSVal))
out := fmt.Sprintln("****") out := fmt.Sprintln("****")
tagKeys := make([]string, len(tags)) tagKeys := make([]string, len(tags))
@ -125,11 +125,11 @@ func (m *MqlSession) ToText(result interface{}) string {
return out return out
} }
func (m *MqlSession) BuildJson(result interface{}) { func (m *Session) BuildJson(result interface{}) {
m.currentQuery.treeifyResult(*(result.(*map[string]graph.TSVal))) m.currentQuery.treeifyResult(*(result.(*map[string]graph.TSVal)))
} }
func (m *MqlSession) GetJson() (interface{}, error) { func (m *Session) GetJson() (interface{}, error) {
m.currentQuery.buildResults() m.currentQuery.buildResults()
if m.currentQuery.isError { if m.currentQuery.isError {
return nil, m.currentQuery.err return nil, m.currentQuery.err
@ -138,7 +138,7 @@ func (m *MqlSession) GetJson() (interface{}, error) {
} }
} }
func (m *MqlSession) ClearJson() { func (m *Session) ClearJson() {
// Since we create a new MqlQuery underneath every query, clearing isn't necessary. // Since we create a new MqlQuery underneath every query, clearing isn't necessary.
return return
} }