Function SQLToWriter

backend/component/export/sql.go:26–52

SQLToWriter streams SQL INSERT statements directly to the writer.

(w io.Writer, engine storepb.Engine, statementPrefix string, result *v1pb.QueryResult)

// SQLToWriter streams SQL INSERT statements directly to the writer.
func SQLToWriter(w io.Writer, engine storepb.Engine, statementPrefix string, result *v1pb.QueryResult) error {
	for i, row := range result.Rows {
		if _, err := w.Write([]byte(statementPrefix)); err != nil {
			return err
		}
		for j, value := range row.Values {
			if j != 0 {
				if _, err := w.Write([]byte{','}); err != nil {
					return err
				}
			}
			if _, err := w.Write(convertValueToBytesInSQL(engine, value)); err != nil {
				return err
			}
		}
		if i != len(result.Rows)-1 {
			if _, err := w.Write([]byte(");\n")); err != nil {
				return err
			}
		} else {
			if _, err := w.Write([]byte(");")); err != nil {
				return err
			}
		}
	}
	return nil
}

// SQLStatementPrefix generates the INSERT INTO statement prefix.
func SQLStatementPrefix(engine storepb.Engine, resourceList []base.SchemaResource, columnNames []string) (string, error) {