wpetit/super-graph
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix issues with mutation SQL

Browse Source
This commit is contained in:
Vikram Rangnekar
2019-10-03 03:08:01 -04:00
parent bcc443bd59
commit a8ad87115e
16 changed files with 317 additions and 266 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
qcode/qcode.go
View File

@ -164,7 +164,7 @@ var opMap = map[parserType]QType{
}
var expPool = sync.Pool{
New: func() interface{} { return new(Exp) },
New: func() interface{} { return &Exp{doFree: true} },
}
func NewCompiler(c Config) (*Compiler, error) {
@ -195,6 +195,7 @@ func NewCompiler(c Config) (*Compiler, error) {
seedExp := [100]Exp{}
for i := range seedExp {
seedExp[i].doFree = true
expPool.Put(&seedExp[i])
}
@ -318,7 +319,6 @@ func (com *Compiler) compileQuery(op *Operation) ([]Select, error) {
}
if fil != nil && fil.Op != OpNop {
if root.Where != nil {
ow := root.Where
@ -695,7 +695,7 @@ func newExp(st *util.Stack, node *Node, usePool bool) (*Exp, error) {
ex = expPool.Get().(*Exp)
ex.Reset()
} else {
ex = &Exp{}
ex = &Exp{doFree: false}
}
ex.Children = ex.childrenA[:0]
@ -881,7 +881,7 @@ func compileFilter(filter []string) (*Exp, error) {
st := util.NewStack()
if len(filter) == 0 {
return &Exp{Op: OpNop}, nil
return &Exp{Op: OpNop, doFree: false}, nil
}
for i := range filter {
@ -893,10 +893,11 @@ func compileFilter(filter []string) (*Exp, error) {
if err != nil {
return nil, err
}
if fl == nil {
fl = f
} else {
fl = &Exp{Op: OpAnd, Children: []*Exp{fl, f}}
fl = &Exp{Op: OpAnd, Children: []*Exp{fl, f}, doFree: false}
}
}
return fl, nil
@ -986,6 +987,7 @@ func (t ExpOp) String() string {
}
func FreeExp(ex *Exp) {
// fmt.Println(">", ex.doFree)
if ex.doFree {
expPool.Put(ex)
}