Method ExecuteNonQueryStatement

client/session.go:527–550

(sql string)

}

func (s *Session) ExecuteNonQueryStatement(sql string) error {
	request := rpc.TSExecuteStatementReq{
		SessionId:   s.sessionId,
		Statement:   sql,
		StatementId: s.requestStatementId,
		FetchSize:   &s.config.FetchSize,
	}
	resp, err := s.client.ExecuteStatementV2(context.Background(), &request)

	if err != nil && resp == nil {
		if s.reconnect() {
			request.SessionId = s.sessionId
			request.StatementId = s.requestStatementId
			resp, err = s.client.ExecuteStatementV2(context.Background(), &request)
		}
	}
	if err != nil {
		return err
	}
	if resp.IsSetDatabase() {
		s.changeDatabase(*resp.Database)
	}
	return VerifySuccess(resp.Status)
}

func (s *Session) changeDatabase(database string) {
	s.config.Database = database