test_cli.c

站长以前写的informix通用开发包源码

#include <stdio.h>

#include "informix.h"

void main()
{
  DB_SEL_DATA sel_data;
  DB_BIND_DATA bind_data;
  char sz_ch[20];
  int i, ret, count;
  double f;
  DB_RPC_DATA rpc_data;

/*putenv("INFORMIXDIR=/u/info");
putenv("INFORMIXSERVER=jfserver");
putenv("ONCONFIG=onconfig.ids73");*/
  if((ret =db_login("shoufei", "informix", "informix")) <0)
  {
    db_logout();
    printf("db_login failed! ret =%d\n", ret);
    return;
  }
/* opr_id, net_id, bureaus, ds_id, settle, src_name, src_ip, src_user, src_pass, src_path, src_format, dst_path, dst_format, drv_path, drv_name, tran_delay, tran_retry, tran_over, file_count, lasttime, turn_prior */
  /*strcpy(sel_data.sqlstm, "select opr_id, net_id, file_count, lasttime from cj_tb_shm");*/
  memset(&sel_data, 0, sizeof(sel_data));
  count =0;
  strcpy(sel_data.sqlstm, "select fee_total from sf_tb_fee");
  sel_data.buf_count =1;
  sel_data.bufs[0] =(char *)&f;
  if((ret =db_select(&sel_data)) <0)
  {
    printf("***** failed! db_select\n");
  }
  else printf("ret =%d, f =%f\n", ret, f);

  memset(&rpc_data, 0, sizeof(rpc_data));
  strcpy(rpc_data.name, "sf_sp_turnon");
  rpc_data.param_count =3;
  rpc_data.params[0] ="72221851";
  rpc_data.params[1] ="111111";
  rpc_data.params[2] ="22";
  for(i =0; i<3; i++)
    rpc_data.col_defs[i].type =SQLT_STR;
  rpc_data.col_defs[0].size =12;
  rpc_data.col_defs[1].size =6;
  rpc_data.col_defs[2].size =2;

  if(db_rpc(&rpc_data) <0)
    printf("db_rpc failed!\n");
  else printf("db_rpc success!\n");

  strcpy(sel_data.sqlstm, "select count(*) from aa where ch=?");
  sel_data.param_count =1;
  sel_data.pbufs_param[0] =sz_ch;
  sel_data.param_defs[0].type =SQLT_STR;
  sel_data.param_defs[0].size =10;
  if(db_sel_init(&sel_data) <0)
  {
    printf("db_sel_init failed!\n");
    db_sel_free(&sel_data);
    db_logout();
    return;
  }
  for(i =0; i<2; i++)
  {
  if(i ==0) strcpy(sz_ch, "bbb");
  else strcpy(sz_ch, "aaa");
  if(db_sel_exec(&sel_data) <0)
  {
    printf("db_sel_exec failed!\n");
    db_sel_free(&sel_data);
    db_logout();
    return;
  }
  if(db_sel_fetch(&sel_data) <=0)
  {
    printf("db_sel_fetch failed!\n");
    db_sel_free(&sel_data);
    db_logout();
    return;
  }
  /*printf("%s, %s, %s, %s\n", sel_data.pbufs[0], sel_data.pbufs[1], sel_data.pbufs[2], sel_data.pbufs[3]);*/
  printf("sz_ch =%s, count =%ld\n", sz_ch, *(int *)sel_data.pbufs[0]);
  }
  db_sel_free(&sel_data);
db_logout();
return;
/*
  bind_data.type =BIND_TYPE_INSERT;
  bind_data.col_count =2;
  bind_data.row_count =1;
  strcpy(bind_data.col_defs[0].name, "ch");
  strcpy(bind_data.col_defs[1].name, "dec");
  bind_data.col_defs[0].type = SQLT_STR;
  bind_data.col_defs[1].type = SQLT_FLT;
  bind_data.col_defs[0].size = 10;
  bind_data.col_defs[1].size = 8;
  strcpy(bind_data.table_name, "aa");

  if(db_bind_alloc(&bind_data) <0)
  {
    printf("db_bind_alloc failed!\n");
    db_bind_free(&bind_data);
    db_logout();
    return;
  }
  strcpy(bind_data.rows[0].cols[0].pvalue, "123456");
  *(double *)bind_data.rows[0].cols[1].pvalue =95154;
  if(db_bind_exec(&bind_data, 1) <0)
  {
    printf("db_bind_exec failed!\n");
    db_bind_free(&bind_data);
    db_logout();
    return;
  }
  db_bind_free(&bind_data);
  db_logout();
*/
}

void log_err_no_warning(char *msg)
{
  printf(msg);
}