Merge branch 'master' into scrolling-rs
This commit is contained in:
commit
5d1ea229a4
10
engine.go
10
engine.go
|
@ -979,18 +979,22 @@ func (engine *Engine) Import(ddlPath string) ([]sql.Result, error) {
|
||||||
scanner.Split(semiColSpliter)
|
scanner.Split(semiColSpliter)
|
||||||
|
|
||||||
session := engine.NewSession()
|
session := engine.NewSession()
|
||||||
session.IsAutoClose = false
|
defer session.Close()
|
||||||
|
err = session.newDb()
|
||||||
|
if err != nil {
|
||||||
|
return results, err
|
||||||
|
}
|
||||||
|
|
||||||
for scanner.Scan() {
|
for scanner.Scan() {
|
||||||
query := scanner.Text()
|
query := scanner.Text()
|
||||||
query = strings.Trim(query, " \t")
|
query = strings.Trim(query, " \t")
|
||||||
if len(query) > 0 {
|
if len(query) > 0 {
|
||||||
result, err := session.Exec(query)
|
result, err := session.Db.Exec(query)
|
||||||
results = append(results, result)
|
results = append(results, result)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
lastError = err
|
lastError = err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
session.Close()
|
|
||||||
return results, lastError
|
return results, lastError
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue