slow_insert.go

// A slower insert that is faster to type.
func (db *DB) ReflectInsert(tablename string, obj interface{}) error {
	base := "INSERT INTO %s(%s) VALUES (%s)"
	count := 1
	var columns []string
	var placeholders []string
	var vals []interface{}

	v := reflect.ValueOf(obj).Elem()
	t := v.Type()

	for index := 0; index < v.NumField(); index++ {
		// // Skip autogenerated fields on insert
		tag := t.Field(index).Tag.Get("db")
		tagName, opts := parseTag(tag)
		if opts.Contains("noinsert") {
			continue
		}

		vals = append(vals, v.Field(index).Interface())
		columns = append(columns, tagName)
		placeholders = append(placeholders, fmt.Sprintf("$%d", count))
		count++
	}

	insert := fmt.Sprintf(
		base,
		tablename,
		strings.Join(columns, ","),
		strings.Join(placeholders, ","))

	// Actual insert
	fmt.Println(insert, vals)
	_, err := db.Exec(insert, vals...)
	return err
}