• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

C++ dbcmd函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了C++中dbcmd函数的典型用法代码示例。如果您正苦于以下问题：C++ dbcmd函数的具体用法？C++ dbcmd怎么用？C++ dbcmd使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。



在下文中一共展示了dbcmd函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C++代码示例。

示例1: init

static int
init(DBPROCESS * dbproc, const char *name)
{
	int res = 0;

	fprintf(stdout, "Dropping %s.%s..%s\n", SERVER, DATABASE, name);
	add_bread_crumb();
	sprintf(cmd, "if exists (select 1 from sysobjects where type = 'U' and name = '%s') drop table %s", name, name);
	dbcmd(dbproc, cmd);
	add_bread_crumb();
	dbsqlexec(dbproc);
	add_bread_crumb();
	while (dbresults(dbproc) != NO_MORE_RESULTS) {
		/* nop */
	}
	add_bread_crumb();

	fprintf(stdout, "Creating %s.%s..%s\n", SERVER, DATABASE, name);

	dbcmd(dbproc, create_table_sql);

	if (dbsqlexec(dbproc) == FAIL) {
		add_bread_crumb();
		res = 1;
	}
	while (dbresults(dbproc) != NO_MORE_RESULTS) {
		/* nop */
	}
	return res;
}
开发者ID:BackupTheBerlios，项目名称:upwatch-svn，代码行数:30，代码来源:bcp.c


示例2: verify_provider_class

/* verify that the provider class is valid(exist in PROVIDER_CLASS_REF) */
int
verify_provider_class(RATE_USAGE_OVERRIDES_STRUCT *struct_ptr, int *count)
{
      int i=0;
      int  ret_code;

	dbcmd(dbproc1, " select count(*) ");
	dbcmd(dbproc1, " from  PROVIDER_CLASS_REF ");
	dbfcmd(dbproc1, " where provider_class = %s", struct_ptr->provider_class);
        if (safe_dbselect(dbproc1, "PROVIDER_CLASS_REF", 
          "verify_provider_class"))
        {
          return(FAILURE);
        }
	 
	dbbind(dbproc1,1,INTBIND,0, count);

	while (dbnextrow(dbproc1) == REG_ROW)
	{
	  i++;
	} /* end of while loop */

        if(check_dbresults(dbproc1,ret_code,"PROVIDER_CLASS_REF",
                                        "verify_provider_class"))
        {
          return(FAILURE);
        }

	return (SUCCESS);
}
开发者ID:huilang22，项目名称:Projects，代码行数:31，代码来源:rate_usage_or_util.c


示例3: delete_col_collector_db

int
delete_col_collector_db()
{
    char *db_string;
    int  i = 0, ret_code;

      dbcmd(dbproc1," delete COL_COLLECTOR ");
      dbcmd(dbproc1, " where ");
      db_string = 
        (char *)convert_to_db_string(col_collector_selected.collector_id);
      dbfcmd(dbproc1, " collector_id = %d",
          atoi(db_string));
      free(db_string);

      if(safe_dbupdate(dbproc1, "COL_COLLECTOR",
            "delete_col_collector_db"))
      {
        return(FAILURE);
      }

      while ((ret_code = dbnextrow(dbproc1)) == REG_ROW)
      {
        if (ret_code == FAIL)
        {
          return(FAILURE);
        }
      }

      if(check_dbresults(dbproc1,ret_code,"COL_COLLECTOR",
              "delete_col_collector_db"))
        return(FAILURE);

      return(SUCCESS);
}
开发者ID:huilang22，项目名称:Projects，代码行数:34，代码来源:col_collector_util.c


示例4: verify_type_id_usg

int
verify_type_id_usg(RATE_USAGE_OVERRIDES_STRUCT *struct_ptr, int *count)
{
      int i=0;
      int  ret_code;

	dbcmd(dbproc1, " select count(*) ");
	dbcmd(dbproc1, " from  USAGE_TYPES ");

	dbfcmd(dbproc1, " where type_id_usg = %s", struct_ptr->type_id_usg);

        if (safe_dbselect(dbproc1, "USAGE_TYPES", 
          "verify_type_id_usg"))
        {
          return(FAILURE);
        }
	 
	dbbind(dbproc1,1,INTBIND,0, count);

	while (dbnextrow(dbproc1) == REG_ROW)
	{
	  i++;
	} /* end of while loop */

        if(check_dbresults(dbproc1,ret_code,"USAGE_TYPES",
                                        "verify_type_id_usg"))
        {
          return(FAILURE);
        }

	return (SUCCESS);
}
开发者ID:huilang22，项目名称:Projects，代码行数:32，代码来源:rate_usage_or_util.c


示例5: init_proc

static RETCODE
init_proc(DBPROCESS * dbproc, const char *name)
{
	RETCODE ret = FAIL;

	if (name[0] != '#') {
		fprintf(stdout, "Dropping procedure %s\n", name);
		add_bread_crumb();
		sprintf(cmd, "DROP PROCEDURE %s", name);
		dbcmd(dbproc, cmd);
		add_bread_crumb();
		dbsqlexec(dbproc);
		add_bread_crumb();
		while (dbresults(dbproc) != NO_MORE_RESULTS) {
			/* nop */
		}
		add_bread_crumb();
	}

	fprintf(stdout, "Creating procedure %s\n", name);
	sprintf(cmd, procedure_sql, name);
	dbcmd(dbproc, cmd);
	if ((ret = dbsqlexec(dbproc)) == FAIL) {
		add_bread_crumb();
		if (name[0] == '#')
			fprintf(stdout, "Failed to create procedure %s. Wrong permission or not MSSQL.\n", name);
		else
			fprintf(stdout, "Failed to create procedure %s. Wrong permission.\n", name);
	}
	while (dbresults(dbproc) != NO_MORE_RESULTS) {
		/* nop */
	}
	return ret;
}
开发者ID:dparnell，项目名称:freetds，代码行数:34，代码来源:rpc.c


示例6: eft_get_status_codes

void eft_get_status_codes()
{
int db_code;
char description[81];
RETCODE ret_code;

 /* this gets called once and hangs around forever */

  description[0] = '\0';
  db_code = 0;

  eft_num_display_statuses = 0;

  if(eft_sel_shell == NULL)
    create_eft_sel_shell(eft_shell); 

  dbcmd(dbeftproc,"select integer_value,display_value from GUI_INDICATOR_VALUES where ");
  dbcmd(dbeftproc,"table_name = 'EFT_TRANS' and field_name = 'trans_status'");
  dbfcmd(dbeftproc, " and language_code = %d", gGUIlanguage );
  br_dbsqlexec(dbeftproc);
  if (Sybase_error)
  {
    dbcancel(dbeftproc);
    return;
  }
  
  while((ret_code = dbresults(dbeftproc)) != NO_MORE_RESULTS)
  {
    if(ret_code == FAIL)
    {
      dbcancel(dbeftproc);
      return;
    }

    dbbind(dbeftproc,1,INTBIND,0,&db_code);
    dbbind(dbeftproc,2,NTBSTRINGBIND,0,description);
    while (dbnextrow(dbeftproc) != NO_MORE_ROWS)
    {
      /* Found an entry. */
      eft_num_display_statuses++;
      eft_display_statuses = (EFT_DB_POPLIST_TYPE *)
	      realloc (eft_display_statuses,eft_num_display_statuses * sizeof (EFT_DB_POPLIST_TYPE));
      eft_display_statuses_list = (XmString *)
	      realloc (eft_display_statuses_list,eft_num_display_statuses * sizeof (XmString));
      eft_display_statuses[eft_num_display_statuses - 1].db_code = db_code;
      strcpy (eft_display_statuses[eft_num_display_statuses - 1].description,description);
      eft_display_statuses_list[eft_num_display_statuses - 1] = XmStringCreateSimple (description);

    }
  }
  if(Sybase_error)
  {
    dbcancel(dbeftproc);
    return;
  }
}
开发者ID:huilang22，项目名称:Projects，代码行数:56，代码来源:eft_poplist_callbacks.c


示例7: get_next_bill_date

int
get_next_bill_date (char *bill_period, char *billing_frequency,
char *prev_cutoff_date, char *next_bill_date)
{
  int ret_code;

  /* Nested select statement -- just one way to do this query */

  dbfcmd(dbproc1, "select convert(char(8), min(ppdd_date), %d) ", gdatefmt);
  dbcmd (dbproc1, "from BILL_CYCLE where ppdd_date in ");
  dbcmd (dbproc1, "(select ppdd_date from BILL_CYCLE ");

  if ((bill_period == NULL) || (strlen(bill_period) == 0))
    dbcmd (dbproc1, "having bill_period = min(bill_period) ");
  else
    dbfcmd(dbproc1, "having bill_period = '%s' ", bill_period);

  if ((billing_frequency == NULL) || (strlen(billing_frequency) == 0))
    dbcmd (dbproc1, "and billing_frequency = min(billing_frequency) ");
  else
    dbfcmd(dbproc1, "and billing_frequency = %s ", billing_frequency);

  if ((prev_cutoff_date == NULL) || (strlen(prev_cutoff_date) == 0))
    dbcmd (dbproc1, "and cutoff_date > getdate()) ");
  else
    dbfcmd(dbproc1, "and cutoff_date > '%s') ", prev_cutoff_date);

  br_dbsqlexec(dbproc1);
  if (Sybase_error)
    {
      dbcancel(dbproc1);
      return(FAILURE);
    }

  while ((ret_code = dbresults(dbproc1)) != NO_MORE_RESULTS)
    {
      if (ret_code != SUCCEED)
        {
          dbcancel(dbproc1);
          return(FAILURE);
        }

      dbbind(dbproc1, 1, NTBSTRINGBIND, 0, next_bill_date);
      while (dbnextrow(dbproc1) != NO_MORE_ROWS); /* empty */
    }

  if (Sybase_error)
    {
      dbcancel(dbproc1);
      return(FAILURE);
    }

  return (SUCCESS);

} /* end get_next_bill_date */
开发者ID:huilang22，项目名称:Projects，代码行数:55，代码来源:custmain_db.c


示例8: delete_overrides_rc_db

int
delete_overrides_rc_db()
{
    char *db_string;
    int  i = 0, ret_code;

      dbcmd(dbproc1," delete OVERRIDES_RC ");
      dbcmd(dbproc1, " where ");
      db_string = 
        (char *)convert_to_db_string(overrides_rc_selected.tax_pkg_inst_id);
      dbfcmd(dbproc1, " (tax_pkg_inst_id = %d",
          atoi(db_string));
      if (atoi(db_string)==0){
        dbfcmd(dbproc1, " or tax_pkg_inst_id is NULL) " );
      }else{
        dbfcmd(dbproc1, ") " );
      }
      free(db_string);
      dbcmd(dbproc1, " and  ");
      db_string = 
        (char *)convert_to_db_string(overrides_rc_selected.element_id);
      dbfcmd(dbproc1, " element_id = %d",
          atoi(db_string));
      free(db_string);
      dbcmd(dbproc1, " and  ");
      db_string = 
        (char *)convert_to_db_string(overrides_rc_selected.geocode);
      dbfcmd(dbproc1, " geocode = '%s'",
          db_string);
      free(db_string);

      if(safe_dbupdate(dbproc1, "OVERRIDES_RC",
            "delete_overrides_rc_db"))
      {
        return(FAILURE);
      }

      while ((ret_code = dbnextrow(dbproc1)) == REG_ROW)
      {
        if (ret_code == FAIL)
        {
          return(FAILURE);
        }
      }

      if(check_dbresults(dbproc1,ret_code,"OVERRIDES_RC",
              "delete_overrides_rc_db"))
        return(FAILURE);

      return(SUCCESS);
}
开发者ID:huilang22，项目名称:Projects，代码行数:51，代码来源:overrides_rc_util.c


示例9: bill_cycle_save_db

/*
*******************************************
*  insert information
*******************************************
*/
int bill_cycle_save_db(BILL_CYCLE_STRUCT *bill_cycle_struct)
{
    int i, ret_code;
    int status;
    char *db_string = NULL;

    /*****************************************
    Insert into BILL_CYCLE;
    *****************************************/

      dbcmd(dbproc1," insert into BILL_CYCLE ");
      dbcmd(dbproc1, " (bill_period,billing_frequency,ppdd_date,");
      dbcmd(dbproc1, " next_ppdd_date,statement_date,cutoff_date,");
      dbcmd(dbproc1, " prep_delay)");
      dbcmd(dbproc1, " values(");
      db_string =
        (char *)convert_to_db_string(bill_cycle_struct->bill_period);
      dbfcmd(dbproc1, " '%s',",db_string);
      free(db_string);
      db_string =
        (char *)convert_to_db_string(bill_cycle_struct->billing_frequency);
      dbfcmd(dbproc1, " %d,",atoi(db_string));
      free(db_string);

      date_time_to_Arbdate(bill_cycle_struct->ppdd_date, 
        bill_cycle_struct->ppdd_time, &(bill_cycle_struct->ppdd_dt));
      dbfcmd(dbproc1, " %t,", &(bill_cycle_struct->ppdd_dt));

      date_time_to_Arbdate(bill_cycle_struct->next_ppdd_date, 
        bill_cycle_struct->next_ppdd_time, &(bill_cycle_struct->next_ppdd_dt));
      dbfcmd(dbproc1, " %t,", &(bill_cycle_struct->next_ppdd_dt));

      date_time_to_Arbdate(bill_cycle_struct->statement_date, 
        bill_cycle_struct->statement_time, &(bill_cycle_struct->statement_dt));
      dbfcmd(dbproc1, " %t,", &(bill_cycle_struct->statement_dt));

      date_time_to_Arbdate(bill_cycle_struct->cutoff_date, 
        bill_cycle_struct->cutoff_time, &(bill_cycle_struct->cutoff_dt));
      dbfcmd(dbproc1, " %t,", &(bill_cycle_struct->cutoff_dt));

      db_string =
        (char *)convert_to_db_string(bill_cycle_struct->prep_delay);
      dbfcmd(dbproc1, " %d)",atoi(db_string));
      free(db_string);

      if (safe_dbupdate(dbproc1, "BILL_CYCLE", "bill_cycle_save_db"))
      {
        return(FAILURE);
      }
      return(SUCCESS);
}
开发者ID:huilang22，项目名称:Projects，代码行数:56，代码来源:bill_cycle_util.c


示例10: pdo_dblib_stmt_execute

static int pdo_dblib_stmt_execute(pdo_stmt_t *stmt)
{
	pdo_dblib_stmt *S = (pdo_dblib_stmt*)stmt->driver_data;
	pdo_dblib_db_handle *H = S->H;
	RETCODE ret;
	
	dbsetuserdata(H->link, (BYTE*) &S->err);
	
	pdo_dblib_stmt_cursor_closer(stmt);
	
	if (FAIL == dbcmd(H->link, stmt->active_query_string)) {
		return 0;
	}
	
	if (FAIL == dbsqlexec(H->link)) {
		return 0;
	}
	
	ret = pdo_dblib_stmt_next_rowset(stmt);
	
	stmt->row_count = DBCOUNT(H->link);
	stmt->column_count = dbnumcols(H->link);
	
	return 1;
}
开发者ID:AmesianX，项目名称:php-src，代码行数:25，代码来源:dblib_stmt.c


示例11: dbcmd

void Query::execute()
{
#ifdef MSSQL
	dbcmd(this->connector->conn_ptr, this->query.c_str() );
	if (dbsqlexec(this->connector->conn_ptr) == FAIL){
		// commits query to db connection 
		status = false;
	} else {
		status = true;
	}
#endif
#ifdef WATCHLIST_MYSQL

	MYSQL *id = &(connector->mysqlID);
	int stat = mysql_query(id, query.c_str());

	string error;

	if (stat){
		this->setStatus(false);
		this->setMessage(mysql_error(id));
	} else {
		this->setStatus(true);
	}
#endif
}
开发者ID:20083017，项目名称:mysql_connector，代码行数:26，代码来源:Query.cpp


示例12: pp_mark_pkg_active

int pp_mark_pkg_active( int pkg_id, int pkg_inst_id, int pkg_inst_id_serv)
{
int status;
RETCODE ret_code;

  dbcmd (dbproc1, "EXEC pp_mark_pkg_active ");
  dbfcmd(dbproc1, " @pkg_inst_id = %d, ", pkg_inst_id);
  dbfcmd(dbproc1, " @pkg_inst_id_serv = %d ", pkg_inst_id_serv);

  if(safe_dbexec(dbproc1,"MARK_PKG_ACTIVE", "mark_pkg_active")) 
    return(FAILURE);

  while ((status = safe_dbresults (dbproc1, "MARK_PKG_ACTIVE", "mark_pkg_active")) != NO_MORE_RESULTS)
  {
    if (status == FAIL) return(FAILURE);

    while ((ret_code = dbnextrow(dbproc1)) != NO_MORE_ROWS)
    {
      if(ret_code == FAIL) return(FAILURE);

      /* process results */

    }
  }

  return (SUCCESS);

}
开发者ID:huilang22，项目名称:Projects，代码行数:28，代码来源:product_pkgs_callbacks.c


示例13: save_pid_to_db

int save_pid_to_db(int id,char* pd)
{
   char szUsername[32] = "sa"; 
   char szPassword[32]= "1qazxsw2*";
   char szDBName[32] = "ids_db";
   char szServer[32] = "10.2.10.201";
   char   sqlquery[1024]={0};
   snprintf(sqlquery,1024,"update ids_policy_event set pid='%s' where id='%d'",pd,id);
   dbinit();
   LOGINREC *loginrec = dblogin();
   DBSETLUSER(loginrec, szUsername);
   DBSETLPWD(loginrec, szPassword);
   DBPROCESS *dbprocess = dbopen(loginrec, szServer);
   if(dbprocess == FAIL)
   {
    LOG_INFO(" Conect MS SQL SERVER fail       ");
    return -1;
   }
   if(dbuse(dbprocess, szDBName) == FAIL)
   {
    LOG_INFO(" Open database name fail");
    return -1;
   }
   dbcmd(dbprocess,sqlquery);
   if(dbsqlexec(dbprocess) == FAIL)
   {
    LOG_INFO("task.cpp dbsqlexec  error!!!");
   }
  dbclose(dbprocess);
  return 0; 
}
开发者ID:crspecter，项目名称:multiprocess_nmap，代码行数:31，代码来源:task.cpp


示例14: InsertSyncLog

int	InsertSyncLog(COUPON_INFO_T *Data, int Count)
{
	char    sql_stm[SMALL_BUFF];
	int	i, count;
	DBPROCESS *dbproc = ConnectDB();

	memset(sql_stm, 0, SMALL_BUFF);

	for(i = 0; i < Count; i++)	{
		sprintf(sql_stm, "Insert INTO T_CouponInfo_Compare2 (CouponNo, MemberCode, ProductCode, UsePeriod, ValidPeriod, StartDate, EndDate, UseDate, Status, RegDate) values ('%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s');", 
				Data[i].CouponID, Data[i].MemberCode, Data[i].ProductID, 
				Data[i].DueMonth, Data[i].ExpireMonth, Data[i].CreateDate, 
				Data[i].ExpireDate, Data[i].RegistDate, Data[i].Status, 
				Data[i].LastUpdateTimeStamp);

		printLog(HEAD, "SQL::(%s)\n", sql_stm);
		dbcmd(dbproc, sql_stm);
		dbsqlexec(dbproc);
		if((count = DBCOUNT(dbproc)) == 0)	{
			printLog(HEAD, "(%s) sql fail ..\n", sql_stm);
		}
	}

	DisConnectDB();
	return	NO_ERROR;
}
开发者ID:k2b3d，项目名称:authsrc，代码行数:26，代码来源:DBProcess.cpp


示例15: dblib_handle_doer

static zend_long dblib_handle_doer(pdo_dbh_t *dbh, const char *sql, size_t sql_len)
{
	pdo_dblib_db_handle *H = (pdo_dblib_db_handle *)dbh->driver_data;
	RETCODE ret, resret;

	dbsetuserdata(H->link, (BYTE*)&H->err);

	if (FAIL == dbcmd(H->link, sql)) {
		return -1;
	}

	if (FAIL == dbsqlexec(H->link)) {
		return -1;
	}

	resret = dbresults(H->link);

	if (resret == FAIL) {
		return -1;
	}

	ret = dbnextrow(H->link);
	if (ret == FAIL) {
		return -1;
	}

	if (dbnumcols(H->link) <= 0) {
		return DBCOUNT(H->link);
	}

	/* throw away any rows it might have returned */
	dbcanquery(H->link);

	return DBCOUNT(H->link);
}
开发者ID:dsp，项目名称:php-src，代码行数:35，代码来源:dblib_driver.c


示例16: sql_cmd

/*
 * Fill the command buffer from a file while echoing it to standard output.
 */
RETCODE 
sql_cmd(DBPROCESS *dbproc)
{
	char line[2048], *p = line;
	int i = 0;
	RETCODE erc=SUCCEED;

	if (!input_file) {
		fprintf(stderr, "%s: error: SQL input file \"%s\" not opened\n", BASENAME, sql_file);
		exit(1);
	}

	while ((p = fgets(line, (int)sizeof(line), input_file)) != NULL && strcasecmp("go\n", p) != 0) {
		printf("\t%3d: %s", ++i, p);
		if ((erc = dbcmd(dbproc, p)) != SUCCEED) {
			fprintf(stderr, "%s: error: could write \"%s\" to dbcmd()\n", BASENAME, p);
			exit(1);
		}
	}

	if (ferror(input_file)) {
		fprintf(stderr, "%s: error: could not read SQL input file \"%s\"\n", BASENAME, sql_file);
		exit(1);
	}

	return erc;
}
开发者ID:RQZeng，项目名称:freetds，代码行数:30，代码来源:common.c


示例17: ext_socket_access_save_db

/*
*******************************************
*  insert information
*******************************************
*/
int ext_socket_access_save_db(EXT_SOCKET_ACCESS_STRUCT *ext_socket_access_struct)
{
    int i, ret_code;
    int status;
    char *db_string = NULL;

    /*****************************************
    Insert into EXT_SOCKET_ACCESS;
    *****************************************/

      dbcmd(dbproc1," insert into EXT_SOCKET_ACCESS ");
      dbcmd(dbproc1, " (ext_contact_id,remote_host,ip_address,");
      dbcmd(dbproc1, " port,timeout, eof_data)");
      dbcmd(dbproc1, " values(");
      db_string =
        (char *)convert_to_db_string(ext_socket_access_struct->ext_contact_id);
      dbfcmd(dbproc1, " %d,",atoi(db_string));
      free(db_string);
      db_string =
        (char *)convert_to_db_string(ext_socket_access_struct->remote_host);
      dbfcmd(dbproc1, " '%s',",db_string);
      free(db_string);
      db_string =
        (char *)convert_to_db_string(ext_socket_access_struct->ip_address);
      dbfcmd(dbproc1, " '%s',",db_string);
      free(db_string);
      db_string =
        (char *)convert_to_db_string(ext_socket_access_struct->port);
      dbfcmd(dbproc1, " %d,",atoi(db_string));
      free(db_string);
      db_string =
        (char *)convert_to_db_string(ext_socket_access_struct->timeout);
      dbfcmd(dbproc1, " %d,",atoi(db_string));
      free(db_string);
      db_string =
          (char *)convert_to_db_string(ext_socket_access_struct->eof_data);
      if (strlen(db_string) == 0)
        dbfcmd(dbproc1, " NULL)",db_string);
      else
        dbfcmd(dbproc1, " %s)",db_string);
      free(db_string);
      if (safe_dbupdate(dbproc1, "EXT_SOCKET_ACCESS", "ext_socket_access_save_db"))
      {
        return(FAILURE);
      }
      return(SUCCESS);
}
开发者ID:huilang22，项目名称:Projects，代码行数:52，代码来源:ext_socket_access_util.c


示例18: syb_exec_immediate

int syb_exec_immediate (char *order)
{
  DBPROCESS * dbp = descriptor[PRIVATE_DESCRIPTOR];
  clear_error ();
  dbcmd (dbp, order);
  dbsqlexec (dbp);
  return error_number;
}
开发者ID:jocelyn，项目名称:EiffelStudio，代码行数:8，代码来源:sybase.c


示例19: next_query

static int
next_query(DBPROCESS *dbproc)
{
	char query_line[4096];
	RETCODE erc;
	
	if (feof(stdin))
		return -1;
			
	fprintf(options.verbose, "%s:%d: Query:\n", options.appname, __LINE__);
	
	/*
	 * Normally, a call to dbcmd() clears the buffer the first time it's 
	 * invoked after a call to dbsqlexec() or dbsqlsend().  If fgets(3) 
	 * returns 0 below, however, we'd indicate "success" without calling
	 * dbcmd().  This would leave the prior query in the buffer, which 
	 * our caller would re-send.  To avoid such nonsense, we invoke
	 * dbfreebuf() as a precaution.
	 */
	 
	dbfreebuf(dbproc); 
	
	while (fgets(query_line, sizeof(query_line), stdin)) {
		/* 'go' or 'GO' separates command batches */
		const char *p = query_line;

		/* Skip past leading white spaces */
		while (isspace((unsigned char) *p))
			p++;
		if (strncasecmp(p, "go", 2) == 0) {
			for (p+=2; isspace((unsigned char) *p); p++) {
				if (*p == '\n')
					return 1;
			}
		}

		fprintf(options.verbose, "\t%s", query_line);
		
		/* Add the query line to the command to be sent to the server */
		erc = dbcmd(dbproc, query_line);
		if (erc == FAIL) {
			fprintf(stderr, "%s:%d: dbcmd() failed\n", options.appname, __LINE__);
			return -1;
		}
	}
	
	if (feof(stdin))
		return dbstrlen(dbproc) > 0? 0 : -1;
			
	if (ferror(stdin)) {
		fprintf(stderr, "%s:%d: next_query() failed\n", options.appname, __LINE__);
		perror(NULL);
		return -1;
	}
	
	return 1;
}
开发者ID:DavidRueter，项目名称:freetds，代码行数:57，代码来源:bsqldb.c


示例20: delete_bill_cycle_db

int
delete_bill_cycle_db()
{
    char *db_string;
    int  i = 0, ret_code;

      dbcmd(dbproc1," delete BILL_CYCLE ");
      dbcmd(dbproc1, " where ");
      db_string = 
        (char *)convert_to_db_string(bill_cycle_selected.bill_period);
      dbfcmd(dbproc1, " bill_period = '%s'",
          db_string);
      free(db_string);
      db_string = 
        (char *)convert_to_db_string(bill_cycle_selected.billing_frequency);
      dbfcmd(dbproc1, " and billing_frequency = %d",
          atoi(db_string));
      free(db_string);
      date_time_to_Arbdate(bill_cycle_selected.next_ppdd_date,
        bill_cycle_selected.next_ppdd_time, 
        &(bill_cycle_selected.next_ppdd_dt));
      dbfcmd(dbproc1, " and next_ppdd_date = %t ",
        &(bill_cycle_selected.next_ppdd_dt));

      if(safe_dbupdate(dbproc1, "BILL_CYCLE",
            "delete_bill_cycle_db"))
      {
        return(FAILURE);
      }

      while ((ret_code = dbnextrow(dbproc1)) == REG_ROW)
      {
        if (ret_code == FAIL)
        {
          return(FAILURE);
        }
      }

      if(check_dbresults(dbproc1,ret_code,"BILL_CYCLE",
              "delete_bill_cycle_db"))
        return(FAILURE);

      return(SUCCESS);
}
开发者ID:huilang22，项目名称:Projects，代码行数:44，代码来源:bill_cycle_util.c



注：本文中的dbcmd函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
C++ dbend函数代码示例发布时间：2022-05-30
下一篇：
C++ dbclose函数代码示例发布时间：2022-05-30
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap