"
-set csvfp [open $unix_file_name]
-
+set datafilefp [open $unix_file_name]
set count 0
-while { [ec_gets_char_delimited_line $csvfp elements] != -1 } {
+set errors 0
+# Continue reading the file till the end but stop when an error
+# occured.
+
+# read line, depending on file type
+if {[string eq $file_type "csv"]} {
+ set line_status [ns_getcsv $datafilefp elements]
+} elseif {[string eq $file_type "tab"]} {
+ set line_status [ec_gets_char_delimited_line $datafilefp elements]
+} elseif {[string eq $file_type "delim"]} {
+ set line_status [ec_gets_char_delimited_line $datafilefp elements $delimiter]
+} else {
+ # no valid filetype chosen
+ set line_status -1
+}
+
+while { $line_status != -1 && !$errors} {
incr count
if { $count == 1 } {
# first time thru, we grab the number of columns and their names
set number_of_columns [llength $elements]
set columns $elements
set product_id_column [lsearch -exact $columns "product_id"]
+ # Caroline@meekshome.com Allows you to specify either the product_id or the sku
+ set sku_column [lsearch -exact $columns "sku"]
} else {
# this line is a product
# (this file used to insert rows into ec_custom_product_field_values, but
# now that is done in upload-2.tcl, so we need to update instead)
# set columns_sql "insert into ec_custom_product_field_values (last_modified, last_modifying_user, modified_ip_address "
-# set values_sql " values (sysdate, $user_id, '$ip' "
+# set values_sql " values (sysdate or now(), $user_id, '$ip' "
# for { set i 0 } { $i < $number_of_columns } { incr i } {
# append columns_sql ", [lindex $columns $i]"
# append values_sql ", '[DoubleApos [lindex $elements $i]]'"
# }
# set sql "$columns_sql ) $values_sql )"
set sql "update ec_custom_product_field_values set last_modified=sysdate, last_modifying_user=:user_id, modified_ip_address=:ip"
+ set moresql ""
- for { set i 0 } { $i < $number_of_columns } { incr i } {
- set var_name "var_$i"
- set $var_name [lindex $elements $i]
- if { $i != $product_id_column } {
- append sql ", [lindex $columns $i]=:$var_name"
- }
+ for { set i 0 } { $i < $number_of_columns } { incr i } {
+ set var_name "var_$i"
+ set $var_name [lindex $elements $i]
+ if { $i != $product_id_column && $i != $sku_column} {
+ append moresql ", [lindex $columns $i]=:$var_name"
+ }
}
- append sql " where product_id=:var_$product_id_column"
+ # Caroline@meekshome.com - see if we have a product_id or need to use the sku
+ if { $product_id_column > -1 } {
+ # product_id supplied
+ append sql "${moresql} where product_id=:var_$product_id_column"
+ if { [catch {db_dml product_update_with_product_id $sql} errmsg] } {
+ append bad_products_sql "$sql\n"
+ doc_body_append "FAILURE! SQL: $sql
$errmsg\n"
+ } else {
+ doc_body_append "Success!
\n"
+ }
+ } elseif { $sku_column > -1 } {
+ append sql "${moresql} where product_id = (select product_id from ec_products where sku = :var_$sku_column)"
+ if { [catch {db_dml product_update_with_sku $sql} errmsg] } {
+ append bad_products_sql "$sql\n"
+ doc_body_append "FAILURE! SQL: $sql
$errmsg\n"
+ } else {
+ doc_body_append "Success!
\n"
+ }
+ } else {
+ ad_return_complaint 1 "Each row must either supply the product_id ($product_id_column) or the sku ($sku_column); number_of_columns: $number_of_columns, columns: $columns"
+ }
- if { [catch {db_dml product_update $sql} errmsg] } {
- append bad_products_sql "$sql\n"
- doc_body_append "FAILURE! SQL: $sql
\n"
- } else {
- doc_body_append "Success!
\n"
- }
}
+
+ # read next line of data file, depending on file type, or end read loop if error.
+ if {[string eq $file_type "csv"]} {
+ set line_status [ns_getcsv $datafilefp elements]
+ } elseif {[string eq $file_type "tab"]} {
+ set line_status [ec_gets_char_delimited_line $datafilefp elements]
+ } elseif {[string eq $file_type "delim"]} {
+ set line_status [ec_gets_char_delimited_line $datafilefp elements $delimiter]
+ } else {
+ # no valid filetype chosen
+ set line_status -1
+ }
+
}
doc_body_append "
@@ -93,7 +146,7 @@
(Note: \"success\" doesn't actually mean that the information was uploaded; it -just means that Oracle didn't choke on it (since updates to tables are considered +just means that the database did not choke on it (since updates to tables are considered successes even if 0 rows are updated). If you need reassurance, spot check some of the individual products.) [ad_admin_footer] "