func (m *qlbStmt) Exec(args []driver.Value) (driver.Result, error) {
	var err error
	if len(args) > 0 {
		m.query, err = queryArgsConvert(m.query, args)
		if err != nil {
			return nil, err
		}
	}

	// Create a Job, which is Dag of Tasks that Run()
	ctx := plan.NewContext(m.query)
	ctx.Schema = m.conn.schema
	job, err := BuildSqlJob(ctx)
	if err != nil {
		return nil, err
	}
	m.job = job

	resultWriter := NewResultExecWriter(ctx)
	job.RootTask.Add(resultWriter)

	job.Setup()
	//u.Infof("in qlbdriver.Exec about to run")
	err = job.Run()
	//u.Debugf("After qlb driver.Run() in Exec()")
	if err != nil {
		u.Errorf("error on Query.Run(): %v", err)
		//resultWriter.ErrChan() <- err
		//job.Close()
	}
	return resultWriter.Result(), nil
}
// Exec executes a query that doesn't return rows, such
// as an INSERT, UPDATE, DELETE
Exec executes a query that doesn't return rows, such
as an INSERT, UPDATE, DELETE
// Exec executes a query that doesn ' t return rows such // as an INSERT UPDATE DELETE
func (m *qlbStmt) Exec(args []driver.Value) (driver.Result, error) {
	var err error
	if len(args) > 0 {
		m.query, err = queryArgsConvert(m.query, args)
		if err != nil {
			return nil, err
		}
	}
	ctx := plan.NewContext(m.query)
	ctx.Schema = m.conn.schema
	job, err := BuildSqlJob(ctx)
	if err != nil {
		return nil, err
	}
	m.job = job
	resultWriter := NewResultExecWriter(ctx)
	job.RootTask.Add(resultWriter)
	job.Setup()
	err = job.Run()
	if err != nil {
		u.Errorf("error on Query.Run(): %v", err)
	}
	return resultWriter.Result(), nil
}
func ( m * qlbStmt ) Exec ( args [ ] driver . Value ) ( driver . Result , error ) { var err error if len ( args ) > 0 { m . query , err = queryArgsConvert ( m . query , args ) if err != nil { return nil , err } } ctx := plan . NewContext ( m . query ) ctx . Schema = m . conn . schema job , err := BuildSqlJob ( ctx ) if err != nil { return nil , err } m . job = job resultWriter := NewResultExecWriter ( ctx ) job . RootTask . Add ( resultWriter ) job . Setup ( ) err = job . Run ( ) if err != nil { u . Errorf ( " " , err ) } return resultWriter . Result ( ) , nil }
Exec executes a query that doesn't return rows, such
as an INSERT, UPDATE, DELETE
Exec executes a query that doesn ' t return rows such as an INSERT UPDATE DELETE
// Create a Job, which is Dag of Tasks that Run() //u.Infof("in qlbdriver.Exec about to run") //u.Debugf("After qlb driver.Run() in Exec()") //resultWriter.ErrChan() <- err //job.Close()