Function act_insert

src/gpre/sql.cpp:3419–3609

//

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

	par_options(&transaction);

	if (MSC_match(KW_CURSOR))
		return act_insert_blob();

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

	gpre_req* request = MSC_request(REQ_insert);
	request->req_trans = transaction;
	gpre_ctx* context = SQE_context(request);

	int count = 0, count2 = 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);
				}
			}

			MSC_push(node, &fields);
			count++;
		} while (MSC_match(KW_COMMA));