Method decodeRows

db/sql/sql.go:1033–1048

(s *schema.Schema, rows *sqlx.Rows, list []*schema.Resource, skipNil, recursive bool)

}

func (tx *Transaction) decodeRows(s *schema.Schema, rows *sqlx.Rows, list []*schema.Resource, skipNil, recursive bool) ([]*schema.Resource, error) {
	for rows.Next() {
		data := map[string]interface{}{}
		rows.MapScan(data)

		var resource *schema.Resource
		resourceData := tx.decode(s, s.GetDbTableName(), skipNil, recursive, data)
		resource, err := schema.NewResource(s, resourceData)
		if err != nil {
			return nil, fmt.Errorf("Failed to decode rows")
		}
		list = append(list, resource)
	}

	return list, nil
}

func (tx *Transaction) decode(s *schema.Schema, tableName string, skipNil, recursive bool, data map[string]interface{}) map[string]interface{} {
	resourceData := map[string]interface{}{}