Function ImportDataStringArray

server/resource/dbfunctions_update.go:1207–1270

(data [][]string, headers []string, entityName string, crud *DbResource, req api2go.Request, transaction *sqlx.Tx)

}

func ImportDataStringArray(data [][]string, headers []string, entityName string, crud *DbResource, req api2go.Request, transaction *sqlx.Tx) []error {
	errs := make([]error, 0)

	uniqueColumns := make([]api2go.ColumnInfo, 0)

	for _, col := range crud.TableInfo().Columns {

		if col.IsUnique {
			uniqueColumns = append(uniqueColumns, col)
		}

	}

	for _, rowArray := range data {

		rowMap := make(map[string]interface{})

		for i, header := range headers {
			rowMap[header] = rowArray[i]
		}
		model := api2go.NewApi2GoModelWithData(entityName, nil, int64(crud.TableInfo().DefaultPermission), nil, rowMap)
		_, err := crud.CreateWithTransaction(model, req, transaction)
		if err != nil {
			errs = append(errs, err)
		}

		if err != nil {
			// create row failed, try to update row by unique columns

			if len(uniqueColumns) > 0 {
				for _, uniqueCol := range uniqueColumns {
					log.Printf("Try to update data by unique column: %v", uniqueCol.ColumnName)
					uniqueColumnValue, ok := rowMap[uniqueCol.ColumnName]
					if !ok || uniqueColumnValue == nil {
						continue
					}
					stringVal, isString := uniqueColumnValue.(string)
					if isString && len(stringVal) == 0 {
						continue
					}
					existingRow, err := crud.GetObjectByWhereClauseWithTransaction(entityName, uniqueCol.ColumnName, uniqueColumnValue, transaction)
					if err != nil {
						continue
					}

					for _, key := range headers {
						existingRow[key] = rowMap[key]
					}

					obj := api2go.NewApi2GoModelWithData(entityName, nil, 0, nil, existingRow)
					_, err = crud.UpdateWithTransaction(obj, req, transaction)
					if err != nil {
						log.Errorf("Failed to update table 873 [%v] update row by unique column [%v]: %v", entityName, uniqueCol.ColumnName, err)
					}
					break

				}
			}