Method dumpOneDatabase

backend/plugin/db/sqlite/dump.go:46–92

(ctx context.Context, out io.Writer)

}

func (d *Driver) dumpOneDatabase(ctx context.Context, out io.Writer) error {
	txn, err := d.db.BeginTx(ctx, &sql.TxOptions{ReadOnly: true})
	if err != nil {
		return err
	}
	defer txn.Rollback()

	// Get all schemas.
	query := "SELECT type, name, sql FROM sqlite_schema;"
	rows, err := txn.QueryContext(ctx, query)
	if err != nil {
		return util.FormatErrorWithQuery(err, query)
	}
	defer rows.Close()

	var sqliteSchemas []sqliteSchema
	for rows.Next() {
		var s sqliteSchema
		var sql sql.NullString
		if err := rows.Scan(
			&s.schemaType,
			&s.name,
			&sql,
		); err != nil {
			return err
		}
		if sql.Valid {
			s.statement = sql.String
		}
		sqliteSchemas = append(sqliteSchemas, s)
	}
	if err := rows.Err(); err != nil {
		return err
	}

	for _, s := range sqliteSchemas {
		// We should skip sqlite sequence table.
		if s.name == "sqlite_sequence" {
			continue
		}
		if _, err := io.WriteString(out, fmt.Sprintf("%s;\n", s.statement)); err != nil {
			return err
		}
	}

	return txn.Commit()
}