Function act_upsert

src/gpre/sql.cpp:4828–5100

//

static act* act_upsert(void)
{
	const TEXT* transaction = NULL;

	par_options(&transaction);

	if (!MSC_match(KW_INTO))
		CPR_s_error("INTO");

	gpre_req* request = MSC_request(REQ_mass_update);
	request->req_trans = transaction;
	gpre_ctx* const context = SQE_context(request);
	gpre_rel* relation = context->ctx_relation;

	int count = 0;
	gpre_lls* fields = NULL;

	//  Pick up a field list

	if (!MSC_match(KW_LEFT_PAREN))
	{
		gpre_nod* list = MET_fields(context);
		count = list->nod_count;
		for (int i = 0; i < count; i++)
			MSC_push(list->nod_arg[i], &fields);
	}
	else
	{
		do
		{
			gpre_nod* node = SQE_field(request, false);

			if (node->nod_type == nod_array)
			{
				node->nod_type = nod_field;

				// Make sure no subscripts are specified

				if (node->nod_arg[1]) {
					PAR_error("Partial insert of arrays not permitted");
				}
			}

			// Dialect 1 program may not insert new datatypes
			if ((SQL_DIALECT_V5 == gpreGlob.sw_sql_dialect) &&
				(nod_field == node->nod_type))
			{
				const USHORT field_dtype =
					((ref*) (node->nod_arg[0]))->ref_field->fld_dtype;

				if ((dtype_sql_date == field_dtype)
					|| (dtype_sql_time == field_dtype)
					|| (dtype_int64 == field_dtype))
				{
					SQL_dialect1_bad_type(field_dtype);
				}
			}