Class: Informix::InsertCursor

Inherits:

CursorBase

• Object
• CursorBase
• Informix::InsertCursor

Defined in:

ext/informixc.c

Instance Method Summary

• #flush ⇒ Object

  cursor.flush => cursor.

• #put(*args) ⇒ Object

  cursor.put(*params).

Methods inherited from CursorBase

#close, #free, #id, #open

Instance Method Details

#flush ⇒ Object

cursor.flush => cursor

Flushes the insert buffer, writing data to disk.

Returns __self__.

# File 'ext/informixc.c', line 3632

static VALUE
rb_inscur_flush(VALUE self)
{
	cursor_t *c;
/*
 * 	EXEC SQL begin declare section;
 */
#line 2807 "informixc.ec"
#line 2808 "informixc.ec"
  char *cid, *did;
/*
 * 	EXEC SQL end   declare section;
 */
#line 2809 "informixc.ec"


	Data_Get_Struct(self, cursor_t, c);
	if (!c->is_open)
		rb_raise(rb_eProgrammingError, "Open the cursor object first");

	did = c->database_id;
/*
 * 	EXEC SQL set connection :did;
 */
#line 2816 "informixc.ec"
  {
#line 2816 "informixc.ec"
  sqli_connect_set(0, did, 0);
#line 2816 "informixc.ec"
  }
	if (SQLCODE < 0)
		raise_ifx_extended();

	cid = c->cursor_id;
/*
 * 	EXEC SQL flush :cid;
 */
#line 2821 "informixc.ec"
  {
#line 2821 "informixc.ec"
  sqli_curs_flush(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cid, 256));
#line 2821 "informixc.ec"
  }
	return self;
}

#put(*args) ⇒ Object

cursor.put(*params)

Binds params as input parameters and executes the insert statement. The records are not written immediatly to disk, unless the insert buffer is full, the flush method is called, the cursor is closed or the transaction is commited.

Examples:

A bulk insert using an insert cursor. Requires a transaction:

db.transaction do |db|
  db.cursor('insert into stock values(?, ?, ?, ?, ?, ?)') |cur|
    cur.open
    # Loading a file separated by '|'
    File.open(filename).each do |line|
      fields = line.split('|')
      cur.put(*fields)
    end
  end
end

# File 'ext/informixc.c', line 3565

static VALUE
rb_inscur_put(int argc, VALUE *argv, VALUE self)
{
	struct sqlda *input;
	cursor_t *c;
/*
 * 	EXEC SQL begin declare section;
 */
#line 2765 "informixc.ec"
#line 2766 "informixc.ec"
  char *cid, *did;
/*
 * 	EXEC SQL end   declare section;
 */
#line 2767 "informixc.ec"


	Data_Get_Struct(self, cursor_t, c);
	if (!c->is_open)
		rb_raise(rb_eProgrammingError, "Open the cursor object first");

	did = c->database_id;
/*
 * 	EXEC SQL set connection :did;
 */
#line 2774 "informixc.ec"
  {
#line 2774 "informixc.ec"
  sqli_connect_set(0, did, 0);
#line 2774 "informixc.ec"
  }
	if (SQLCODE < 0)
		raise_ifx_extended();

	input = &c->daInput;
	cid = c->cursor_id;

	bind_input_params(c, argv);
	if (argc != input->sqld)
		rb_raise(rb_eArgError, "wrong number of arguments (%d for %d)",
			argc, input->sqld);

/*
 * 	EXEC SQL put :cid using descriptor input;
 */
#line 2786 "informixc.ec"
  {
#line 2786 "informixc.ec"
  sqli_curs_put(ESQLINTVERSION, sqli_curs_locate(ESQLINTVERSION, cid, 256), input, (char *)0);
#line 2786 "informixc.ec"
  }
	clean_input_slots(c);
	if (SQLCODE < 0)
		raise_ifx_extended();

	/* XXX 2-448, Guide to SQL: Sytax*/
	return INT2FIX(sqlca.sqlerrd[2]);
}