使用CONCAT生成批量INSERT时IF()函数报错问题求助

问题根源 #

1. CONCAT的NULL特性：MySQL中CONCAT函数只要有一个参数是NULL，整个拼接结果就会变成NULL，导致含NULL字段的记录无法生成有效的INSERT语句。
2. 语法错误：原语句中IF(partner.factura_regimen_fiscal IS NULL," ", partner.factura_regimen_fiscal)的引号嵌套混乱，同时字段引用方式错误（将字段名作为字符串拼接，而非直接引用字段值），导致MySQL解析失败。

修正方案 #

核心处理点 #

• 用IFNULL()或COALESCE()将NULL字段转换为合法值：
  • 字符串类型字段：若要插入空字符串，用IFNULL(field, '')；若要插入SQL的NULL值，用IFNULL(field, 'NULL')（此处是字符串'NULL'，生成INSERT时会解析为SQL关键字NULL）。
• 修正引号嵌套：统一用单引号包裹字符串，内部嵌套单引号用\'转义；JSON内容中的双引号用\"转义。
• 正确引用字段：直接将字段作为CONCAT的参数，而非把字段名嵌入字符串中。

修正后的查询语句 #

SELECT CONCAT(
    "INSERT INTO `erp_gamma`.`partner` (`n_partner_id`, `n_activo`, `c_apellido_materno`, `c_apellido_paterno`, `c_correo_electronico`, `n_dias_credito`, `c_identificador`, `c_json`, `d_limite_credito`, `c_nombre`, `n_persona_fisica`, `c_razon_social`, `c_rfc`, `n_status`, `n_corporativo_sucursal_id`, `n_partner_tipo_id`, `c_codigo_postal`, `n_numero_telefonico`, `create_date`, `update_date`, `c_cp_fiscal`, `c_regimen_fiscal`, `c_sistema_id_serie_numerico`, `n_sistema_id_numerico`, `c_id_migracion`) VALUES (",
    "NULL, '1', ",
    IFNULL(CONCAT("'", REPLACE(partner.contacto_nombre, "'", "\\'"), "'"), "''"), ", ",
    IFNULL(CONCAT("'", REPLACE(partner.contacto_nombre, "'", "\\'"), "'"), "''"), ", ",
    IFNULL(CONCAT("'", REPLACE(partner.contacto_email, "'", "\\'"), "'"), "''"), ", ",
    IFNULL(partner.control_dias_credito, "NULL"), ", ",
    "'11111', ",
    "'{\"id_calle_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_calle, '"', '\\"'), ""), "\",\"id_colonia_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_colonia, '"', '\\"'), ""), "\",\"id_ciudad_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_ciudad, '"', '\\"'), ""), "\",\"id_estado_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_estado, '"', '\\"'), ""), "\",\"id_cp_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_cp, '"', '\\"'), ""), "\",\"id_telefono2_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_telefono2, '"', '\\"'), ""), "\",\"id_celular_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_telefono3, '"', '\\"'), ""), "\",\"id_fax_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_fax, '"', '\\"'), ""), "\",\"id_web_cliente_md\":\"", IFNULL(REPLACE(partner.contacto_web, '"', '\\"'), ""), "\",\"id_tipoprecio_cliente_md\":\"", IFNULL(REPLACE(partner.control_tipo_precio_default, '"', '\\"'), ""), "\",\"id_calle_rfc_cliente_md\":\"", IFNULL(REPLACE(partner.factura_calle, '"', '\\"'), ""), "\",\"id_colonia_rfc_cliente_md\":\"", IFNULL(REPLACE(partner.factura_colonia, '"', '\\"'), ""), "\",\"id_ciudad_rfc_cliente_md\":\"", IFNULL(REPLACE(partner.factura_ciudad, '"', '\\"'), ""), "\",\"id_estado_rfc_cliente_md\":\"", IFNULL(REPLACE(partner.factura_estado, '"', '\\"'), "\"}'"), ", ",
    IFNULL(partner.control_limite_credito, "NULL"), ", ",
    IFNULL(CONCAT("'", REPLACE(partner.contacto_nombre, "'", "\\'"), "'"), "''"), ", ",
    "'1', ",
    IFNULL(CONCAT("'", REPLACE(partner.factura_nombre, "'", "\\'"), "'"), "''"), ", ",
    IFNULL(CONCAT("'", REPLACE(partner.factura_rfc, "'", "\\'"), "'"), "''"), ", ",
    "'1', '122', '1', ",
    IFNULL(CONCAT("'", REPLACE(partner.contacto_cp, "'", "\\'"), "'"), "''"), ", ",
    IFNULL(CONCAT("'", REPLACE(partner.contacto_telefono1, "'", "\\'"), "'"), "''"), ", ",
    "now(), now(), ",
    IFNULL(CONCAT("'", REPLACE(partner.factura_cp, "'", "\\'"), "'"), "''"), ", ",
    IFNULL(CONCAT("'", REPLACE(partner.factura_regimen_fiscal, "'", "\\'"), "'"), "''"), ", ",
    "'TP1_20', '20', ",
    IFNULL(CONCAT("'", REPLACE(partner.sku, "'", "\\'"), "'"), "''"),
    ");"
)
FROM partner
WHERE partner.tipo_partner = 1 AND partner.status = 1;

关键细节说明 #

• 特殊字符转义：用REPLACE()处理字符串中的单引号和JSON中的双引号，避免生成的INSERT语句出现语法错误。
• NULL处理：
  • 字符串字段：用IFNULL(CONCAT("'", REPLACE(field, "'", "\\'"), "'"), "''")，将NULL转为空字符串''，同时转义单引号。
  • 数值字段：用IFNULL(field, "NULL")，将NULL转为SQL关键字NULL（不加引号）。
• JSON拼接：单独处理JSON内容中的每个字段，转义双引号，确保JSON格式正确。

内容的提问来源于stack exchange，提问作者Bernardo Uriostegui