DAS 1.1测试时内部服务器在处理接收的单据时崩溃的情况(有产生crash文件).导致程序不再进行后续处理.

在测试环境已出现两种错误配置导致崩溃的情况。

为此已增加启动时校验规则配置功能处理这类问题.

情形1：<command>语句的别名字段在目标表中不存在

产生异常的代码位置及说明如下:

for (int col=0;col<fld_num;col++) {

说明dxi_ddd的配置文件错误.检查后确定错误的配置项如下指示:

       USEDBC(pdbor,src_ds_->dbc_name_.c_str());
        ///< 检查select语句配置是否正确,包括是否是有效的SELECT,及目标表是否存在对应字段
        /// cmd_可能已经有where条件了,且可能有参数:@参数名
        SelectNode parser;
        parser.SetDbAccessor(pdbor);
        try {
            parser.Parse(table->cmd_.cmd_.c_str());        
        }catch(...) {
            return -1;
        }
        ///< 不查任何记录,只用来检查字段
        parser.SetClauseString(SelectNode::SC_WHERE,"0>0");
        string sql = parser.GetCookedSQL();
        AUTO_QUERY_RECORDSET(CRecordset,prs,pdbor);
        prs = pdbor->Query(adCmdText,sql.c_str());
        if (prs==0) {
            return -1;
        }
        int fld_num = prs->GetFieldCount();
        for (int i=0;i<fld_num;i++) {
            FieldInfo fld;
            prs->GetFieldInfo(i,&fld);

            CAutoVector<stFieldInfo*>::iterator it_fld = ti->fields_.begin();
            bool found = false;
            while(it_fld!=ti->fields_.end()) {
                stFieldInfo *fi = *it_fld;
                if (stricmp(fld.m_strName,fi->name_.c_str())==0) {
                    found = true;
                    break;
                }
                it_fld++;
            }
            if (!found) {
                nlogger_->log(LO_STDOUT|LO_FILE,SEVERITY_ERROR,"CRule::check_dest_db,表%s映射语句错误,没有字段%s.n",dest_ds_->dbc_name_.c_str(),table->name_.c_str(),fld.m_strName);
                return -1;
            }
        }

情形2: 任务主键列在<src_db>的<key_field>中不存在

规则的<src_db>的<key_field>内容和tb_change_log的app_key的列不一致.
导致以下代码位置产生问题:

int dxi_ddd_ns::CTask::HandleTable(CTableRelationNode *node,CMsg *msg) {
string tbl_name = node->GetName();
CTable *table = rule_->find_table(tbl_name.c_str());

RuleCommand *rc = &table->cmd_;
///< 确定对应表的抽取语句(参数化SQL)
string sql = rc->cmd_;
///< 确定参数(父表对应字段的值)
int para_num = rc->GetParamNum();
vector<string> vs;
for (int k=0;k<para_num;k++) {
stParamPair *pp = rc->GetParam(k);
CTaskKey *key = find_key(pp->name_.c_str());
///< @note 如果上述配置错误,会导致key==0,下面的语句产生异常.
///< 增加启动时检查配置后可以assert(key!=0)
string val = key->field_val_;
vs.push_back(val);
}
///< 生成最终执行的SQL语句
char *buffer;
if (rc->Instance(&buffer,vs))
return -1;
sql = buffer;
delete []buffer;

USEDBC(pdbor,rule_->src_ds_->dbc_name_.c_str());
AUTO_QUERY_RECORDSET(CRecordset,pdbor);
prs = pdbor->Query(adCmdText,sql.c_str());
if (prs==0) {
return -1;
}

if (prs->ISEOf()) ////< 如果没有查找到数据则不继续处理
return 0;

int rs_num = msg->GetRowsets();
string para_name = LogMsg(INNER_TABLE_FMT,rs_num+1);
msg->AddParam(para_name.c_str(),tbl_name.c_str());
CRowset *rs = new CRowset;
msg->AddRowset(rs);
stRowsetInfo *ri = new stRowsetInfo;
ri->rs_ = rs;
ri->tbl_name_ = tbl_name;
rss_[tbl_name] = ri;

if (RecordFieldToRowset(prs,rs))
return -2;

while(!prs->ISEOf()) {
if (RecordToRowset(prs,rs))
return -4;
if (HandleDetail(node,msg))
return -5;
prs->Move();
}


return 0;
}

通过增加启动时校验规则,发现和报告此类配置错误.

增改的代码如下:
(1)dxi_ddd.cpp
CRule::check_src_db增加以下代码
///< 检查主表的映射语句中的参数是否与key_field一致
CTable *table = this->find_table(dest_master_table_name_.c_str());
RuleCommand *rc = &table->cmd_;
string sql = rc->cmd_;
int para_num = rc->GetParamNum();
vector<string> vs;
for (int k=0;k<para_num;k++) {
stParamPair *pp = rc->GetParam(k);
CTaskKey *key = ::find_key(pp->name_.c_str(),this->src_keys_);
if (key==0) {
nlogger_->log(LO_STDOUT|LO_FILE,SEVERITY_DEBUG,"CRule::check_src_db()%s.配置错误:主表的<command>参数没有出现在<key_field>中.n",
src_ds_->dbc_name_.c_str(),ti->name_.c_str());
return -1;
}
}

////////////////////////////////////////////////////////////////////////////////
CTaskKey* find_key(const char *key_name,CAutoVector<CTaskKey*> &keys) {
CAutoVector<dxi_ddd_ns::CTaskKey*>::iterator iter = keys.begin();
while(iter!=keys.end()) {
dxi_ddd_ns::CTaskKey *key = *iter;
if (stricmp(key->field_name_.c_str(),key_name)==0)
return key;
iter++;
}
return 0;
}
////////////////////////////////////////////////////////////////////////////////
CTaskKey* CTask::find_key(const char *key_name) {
return ::find_key(key_name,keys_);
}

(2)dxi_ddd.h using namespace dxi_ddd_ns; CTaskKey* find_key(const char *key_name,CAutoVector<CTaskKey*> &keys);

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!