Method: Mysql#query

Defined in:
ext/mysql.c

#query(sql) ⇒ Object

query(sql)



755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
 
# File 'ext/mysql.c', line 755

static VALUE query(VALUE obj, VALUE sql)
{
int loop = 0;
MYSQL* m = GetHandler(obj);
Check_Type(sql, T_STRING);
if (GetMysqlStruct(obj)->connection == Qfalse) {
    rb_raise(eMysql, "query: not connected");
}
if (rb_block_given_p()) {
	if (mysql_real_query(m, RSTRING_PTR(sql), RSTRING_LEN(sql)) != 0)
 mysql_raise(m);
	do {
 MYSQL_RES* res = mysql_store_result(m);
 if (res == NULL) {
		if (mysql_field_count(m) != 0)
  mysql_raise(m);
 } else {
		VALUE robj = mysqlres2obj(res);
		rb_ensure(rb_yield, robj, res_free, robj);
 }
#if MYSQL_VERSION_ID >= 40101
 if ((loop = mysql_next_result(m)) > 0)
    	mysql_raise(m);
	} while (loop == 0);
#else
	} while (0);
#endif
	return obj;
}