MySQL数据库访问构件的实现.doc

MySQL数据库访问构件的实现摘要：本文阐述了MySQL数据库访问构件的实现原理，并通过实例详细地描述了应用软件调用该构件接口的使用方法。关键字：MySQL;数据库访问构件;数据库1. 引言MySQL是一个开放源码的小型关联式数据库管理系统，开发者为瑞典MySQL AB公司，目前已被Oracle公司收购。由于其体积小、速度快、总体拥有成本低，开放源码等诸多特点，MySQL已被广泛地应用在Internet网站、中小型软件系统中。MySQL提供各种语言的数据库访问接口，应用软件可通过调用其接口函数完成对数据库的操作与访问。在实际工程应用中，笔者发现在软件编码中直接调用MySQL接口函数访问数据库存在以下弊端：1) 需在程序代码中拼写SQL语句，由于SQL语法的严格规定，导致简单的SQL语句拼写工作，也需程序员耗费一定的时间进行相应的调试。2) 为实现数据库服务器的双机同步处理，需要在调用MySQL接口函数的代码中，增加当前服务器状态的判定，降低了代码的简洁性，增加了程序的复杂性、程序的维护成本。3) 由于调用MySQL查询接口所返回的结果集为字符串形式，因此，应用软件必须对结果集进行格式转换，并且当结果集中有NULL指针时，有可能格式转换异常，从而引起应用软件的异常。4) 当应用软件进行升级、重构时，需在代码中进行大量重复地工作。为了避免以上问题，笔者根据软件工程中封装变化的原理，构建了一个MySQL数据库访问构件(适用于C/C+)。2. 实现原理应用软件通过调用该数据库构件接口进行数据库访问，可解决直接调用MySQL接口所造成的种种弊端，在该数据库访问构件中，笔者利用C+的模板与运行时动态类型识别技术，实现了以下功能：1) SQL语句的自动拼写功能。2) MySQL数据库访问的连接、查询、修改、删除接口。3) 数据库服务器双机同步处理。4) 根据应用软件所指定的查询结果集的数据类型，自动进行结果集的格式转换。通过应用该构件，应用软件可按以下构架模式完成对MySQL数据库访问与操作，如图：图 1应用软件调用MySQL数据库访问构件关系图构架描述：应用软件根据访问具体需求调用相应构件接口，由构件完成相应数据库访问的具体处理事务，并将处理结果返还给应用软件，该构件有利于减少应用软件对数据库编程接口的依赖，在一定程度上提高了应用软件的可移植性。MySQL数据库访问构件使用方法在该小节中通过举例，详细说明了数据库访问构件查询、修改、删除等接口的使用方法。假定在MySQL的TEST库中存在数据库表Employee,该表结构定义如下：表 1Employee表结构字段标识类型范围查询条件存储要求备注Namechar10主关键字学生姓名FlagTinyint Unsigned1-2性别1:男,2:女OldTinyint Unsigned0-255年龄AddressChar100地址TelChar20联系电话3.1 查询接口使用方法调用MySQL数据库访问构件进行查询处理时，按以下步骤实施：1) 应用进程设置数据库句柄、表名、所查询字段、以及数据结构集。2) 调用数据库访问构件中查询接口。3) 在构件查询处理中，通过判定当前数据库服务器主备机状态，确定是否执行相应查询处理，并自动拼写相应的SQL语句，调用MySQL接口，执行相应的查询处理。4) 数据库访问构件对查询结果集进行格式转换，输出应用进程所预定义的数据类型。5) 应用进程获得格式化结果集。查询处理的序列图如下：图 2查询处理序列图在本文中所定义的查询结果集接口如下表：表 2Employee表查询结构集接口定义接口名Employee接口描述应用进程查询数据库的结果集接口采用紧缩形式，按一个字节对齐数据类型定义说明值域备注Charname11姓名最多10个字符或5个汉字Charflag性别1-2shortold年龄0-255性别,1:男,2:女Charaddress101地址最多100个字符或50个汉字chartel21联系电话最多20个字符查询处理代码实例：char cond100;/查询条件缓冲区struct Employee m;Sesql data(DB_TEST,Employee);/DB_TEST:数据库句柄,Student:访问表名sprintf(cond,Name=%s,name);/查询条件data.add_sel_part_field(Name,T_STRING,11);/字段名,输出结构集name类型,长度data.add_sel_part_field(Flag,T_UCHARINT);/字段名,输出结构集flag类型data.add_sel_part_field(Old,T_USHORT);/字段名,输出结构集Old类型 data.add_sel_part_field(Address,T_STRING,101);/字段名,输出结构集Address类型,长度data.add_sel_part_field(Tel,T_STRING,21);/字段名,输出结构集Tel类型,长度data.add_sel_cond(cond);/设置查询条件int num = data.excu_sel();/执行查询处理，并返回符合条件记录行数/循环输出记录信息for(int i = 0; inum; i+)data.set_all_items(char*)&m);/输出一行格式化记录printf(name=%s,flag=%d,old=%d,address=%s,tel=%sn,,m.flag,m.old,m.address,m.tel); 3.2 更新接口使用方法调用MySQL数据库访问构件进行数据更新处理时，按以下步骤实施：1) 应用进程设置数据库句柄、表名、所更新字段、以及相应数据。2) 调用数据库访问构件中更新处理接口。3) 在数据库访问构件的更新处理中，通过判定当前数据库服务器主备机状态，确定是否执行更新处理，并根据传入数据类型自动拼写相应SQL语句, 调用MySQL接口，执行数据库更新处理。4) 当MySQL数据库底层接口完成更新操作处理后，返回其处理结果。5) 数据库访问构件将处理结果返回应用进程。更新处理的序列图如下：图 3更新处理序列图更新处理代码实例：struct student m;strcpy(, “QiaoYang”);/设置更新姓名m.flag = 2; /女m.old = 29; /年龄strcpy(m.address,“江苏南京白下区”);strcpy(m.tel，);char cond100;/更新条件缓冲区 Sesql data(DB_TEST,Employee); /DB_TEST:数据库句柄,Employee:访问表名sprintf(cond,Name=%s,); /设置查询条件data.add_upd_field(Name,);/更新字段名,数值data.add_upd_field(Flag,(int)m.flag);/更新字段名,数值data.add_upd_field(Old,(int)m.old);/更新字段名,数值data.add_upd_field(Address,(char*)m.address);/更新字段名,数值data.add_upd_field(Tel,(char*)m.tel);/更新字段名,数值data.add_sel_cond(cond);/设置更新条件int rez = data.modify();/当存在符合条件的记录时，更新相应记录集，/否则插入新记录，同时返回处理成功或失败标志3.3 删除接口使用方法调用MySQL数据库访问构件进行数据删除处理时，按以下步骤实施： 1) 应用进程设置数据库句柄、表名、删除条件。2) 调用数据库访问构件中删除处理接口。3) 在数据库访问构件的删除处理中，通过判定当前数据库服务器主备机状态，确定是否执行删除处理，并自动拼写相应SQL语句,调用MySQL接口，执行数据库删除处理。4) 当MySQL底层接口完成数据库删除操作处理后，返回相应处理结果。5) 数据库访问构件将处理结果返回应用进程。删除处理的序列图如下：图 4删除处理序列图删除处理代码实例：char cond100;/删除条件缓冲区Sesql data(DB_TEST,Employee); /DB_TEST:数据库句柄, Employee:访问表名sprintf(cond,Name=%s,name); /设置删除条件int rez = data.excu_del(cond