globals "globals.4gl"
define constant mv_limit=1000
define mv_serial integer


code
char *A4GLSQLCV_get_sqlconst(char *cval);
/* Input binding for the fetch */
extern struct BINDING *ibind;
/* Output bindings for the Insert and Update */
extern struct BINDING *obind_i;
extern struct BINDING *obind_u;
extern int obind_i_cnt; /* Count -noentry/noeditadd fields are excluded from insert list too */
extern int obind_u_cnt; /* Count -serial/noentry   fields are excluded from update list too */
static void do_execute_sql(struct BINDING *ibind, int nbind,char *sql) ;
static void do_actual_fetch(char *lv_c, int x,int y,int nf,struct BINDING *ibind) ;
endcode


{
# These functions do all the SQL processing
}


################################################################################
FUNCTION dbi_fill_query_rows_table(lv_tabno,lv_str)
define lv_tabno integer
define lv_str char(5000)
define lv_cnt integer
define lv_id integer

call list_init(lv_tabno)

if lv_str is null or lv_str matches " " then
	return 
end if

prepare p_make_table from lv_str
declare c_make_table cursor for p_make_table
let lv_cnt=1

foreach c_make_table into lv_id

	call list_add(lv_tabno,lv_cnt,lv_id)

	if lv_cnt>mv_limit then
		error "Too many rows - limiting to first ",mv_limit
		exit foreach
	end if
	let lv_cnt=lv_cnt+1
end foreach

return lv_cnt

END FUNCTION


################################################################################
FUNCTION dbi_fetch(lv_tabno,lv_sql,lv_pos)
define lv_tabno integer
define lv_sql char(5000)
define lv_pos integer
define lv_id integer
define lv_c char(20)
define a integer
define lv_p char(20)

let lv_id=list_get(lv_tabno,lv_pos)


IF lv_pos<0 THEN
	ERROR "Some error getting unique ID"
	RETURN
end if
whenever error stop

LET lv_c="c_get_row",lv_tabno using "<<<<"


IF gv_prepared[lv_tabno] IS NULL OR gv_prepared[lv_tabno]=0 THEN 
		let lv_p="p_get_row",lv_tabno using "<<<<"
		PREPARE _variable(lv_p) FROM lv_sql
		DECLARE _variable(lv_c) CURSOR FOR _variable(lv_p)
		LET gv_prepared[lv_tabno]=1
END IF


#whenever error continue
OPEN   _variable(lv_c) using lv_id

if sqlca.sqlcode<0 then
	error "Some error opening cursor"
	return
end if
#whenever error stop


let sqlca.sqlcode=0

code
        for (a=0;a<gv_fields;a++) {
                A4GL_setnull(gv_dtypes[a],(void *)gv_field_data[a],gv_dtypesize[a]);
        }

	do_actual_fetch(lv_c,2,1,gv_fields,ibind);
endcode

if sqlca.sqlcode<0 then
	error "Some error fetching cursor:",sqlca.sqlcode
end if

if sqlca.sqlcode=100 then
	error "NOT FOUND ....lv_c=",lv_c clipped," lv_id=",lv_id," sql=",lv_sql clipped  sleep 1
end if

END FUNCTION


################################################################################
FUNCTION dbi_get_unique_where(lv_tabno,lv_pos)
DEFINE lv_tabno integer
DEFINE lv_str char(256)
DEFINE lv_id integer
DEFINE lv_pos integer


let lv_id=list_get(lv_tabno,lv_pos)

IF lv_pos>=0 THEN
	LET lv_str=dbi_get_rowid() CLIPPED, " = ",lv_id
ELSE
	ERROR "Some error getting unique ID"
	LET lv_str="1=0"
END IF

RETURN lv_str

END FUNCTION





################################################################################
FUNCTION dbi_get_Rowid()
define lv_rowid char(80)
LET lv_rowid="rowid"

code
{
char *ptr;
ptr=A4GLSQLCV_get_sqlconst("ROWID");
if (ptr) strcpy(lv_rowid, ptr);
}
endcode

return lv_rowid clipped
END FUNCTION






################################################################################
FUNCTION dbi_last_Serial()
	return mv_serial
END FUNCTION

################################################################################
FUNCTION dbi_execute_sql(lv_tabno,lv_sql,lv_thispos)
define lv_sql char(10000)
define lv_thispos integer
define lv_tabno integer
	execute immediate lv_sql
	call list_remove(lv_tabno,lv_thispos)
return 1
END FUNCTION


################################################################################
FUNCTION dbi_execute_sql_using_obind_i(lv_sql,lv_nextcnt,lv_tabno)
define lv_sql char(10000)
define lv_tabno integer
define lv_nextcnt integer
define lv_rowid integer
initialize mv_serial to null
code
	A4GL_trim(lv_sql);
	do_execute_sql(obind_i,obind_i_cnt,lv_sql);
        if (a4gl_sqlca.sqlcode<0)  {
			A4GL_chk_err(0,_module_name);
        }
endcode

if sqlca.sqlcode<0 then
	Error "FAILED:",sqlca.sqlcode
	return 0
end if
let mv_serial=sqlca.sqlerrd[2]
let lv_rowid=sqlca.sqlerrd[6]

if lv_rowid>0 then
	call list_add(lv_tabno,lv_nextcnt,lv_rowid)
else
	error "Unable to identify new row - not added to list"
end if
return 1
END FUNCTION

################################################################################
FUNCTION dbi_execute_sql_using_obind_u(lv_sql)
define lv_sql char(10000)
code
        A4GL_trim(lv_sql);
	do_execute_sql(obind_u,obind_u_cnt,lv_sql);
        //if (a4gl_sqlca.sqlcode<0)  {
                        //A4GL_chk_err(0,_module_name);
        //}
endcode

if sqlca.sqlcode<0 then
        Error "FAILED:",sqlca.sqlcode
        return 0
end if
return 1
END FUNCTION


#******************************************************************************************************************************/

{

These are the really lowlevel stuff - the sort of stuff that the 4GL compiler couldn't take care of
automatically...

For non-EC generation - this is trivial, but for EC generated code, we've got to do a lot more work...
}

code


static void do_actual_fetch(char *lv_c, int x,int y,int nf,struct BINDING *ibind) {
A4GL_trim(lv_c);
	A4GL_fetch_cursor(lv_c, 2,1,gv_fields,ibind);
}

static void do_execute_sql(struct BINDING *ibind, int nbind,char *sql) { 
	A4GLSQL_execute_implicit_sql(A4GL_prepare_select(ibind,nbind,0,0,sql,"dbi",0,1,0),1,0,0); 
}


endcode


function dbi_get_datatype(lv_ct)
define lv_ct char(256)
define lv_col char(256)
define lv_tab char(256)
define lv_dtype integer
define lv_size integer
define lv_found integer

if lv_ct not matches "*.*" then
	return 0 # Dont know
end if
let lv_dtype=0

code
{
char *ptr;
ptr=strchr(lv_ct,'.');
*ptr=0;
ptr++;
strcpy(lv_tab,lv_ct);
strcpy(lv_col,ptr);
A4GL_trim(lv_tab);
A4GL_trim(lv_col);
lv_found=A4GL_read_columns(lv_tab, lv_col,&lv_dtype, &lv_size);
}
endcode



#select coltype into lv_dtype from systables,syscolumns
#where systables.tabid=syscolumns.tabid 
#and tabname=lv_tab 
#and colname=lv_col

if lv_found=0 then
	error "Unable to get datatype for column : ", lv_ct clipped sleep 1
end if
return lv_dtype

end function