搜索
首页数据库mysql教程达梦(5)通过DCI实现增删改查

达梦有仿照OCI(Oracle Call Interface)实现了一套DCI 的接口实现。具体在 DM_program p261 中有说明。我照着这个实现编译了下,发现可能依文档编译时有点问题,把有问题的地方改了下,记录在这。 VS 设置: 常规 - 输出目录 - c:\dmdbms\bin 备注: 为了省事这

达梦有仿照OCI(Oracle Call Interface)实现了一套DCI 的接口实现。具体在 > p261

中有说明。我照着这个实现编译了下,发现可能依文档编译时有点问题,把有问题的地方改了下,记录在这。
VS 设置:

常规 -> 输出目录 -> c:\dmdbms\bin
备注: 为了省事这样弄的,实际发布时,把C:\dmdbms\bin下的.dll文件都复制过去就行了。
C/C++ -> 常规 -> 附加包含目录 -> c:\dmdbms\include 链接器 -> 附加库目录 -> c:\dmdbms\include 链接器 -> 附加依赖项 -> dmoci.lib
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <malloc.h>

#include "DCI.h"

/*   声明句柄  */  
OCIEnv    *envhp;      /*   环境句柄    */  
OCISvcCtx  *svchp;      /*   服务环境句柄  */  
OCIServer    *srvhp;       /*   服务器句柄  */  
OCISession   *authp;       /*   会话句柄    */  
OCIStmt      *stmthp;      /*   语句句柄    */  
OCIDescribe  *dschp;      /*   描述句柄    */  
OCIError     *errhp;       /*   错误句柄    */  
OCIDefine   *defhp[3];      /*   定义句柄    */  
OCIBind    *bidhp [4];     /*   绑定句柄    */  
sb2      ind[3];       /*   指示符变量  */  

/*   绑定select结果集的参数  */  
text       szpersonid[11];    /*   存储personid列  */  
text       szsex[2];      /*   存储sex列  */  
text       szname[51];     /*   存储name列  */  
text       szemail[51];     /*   存储mail列  */  
text       szphone[26];    /*   存储phone列  */  
char       sql[256] = {0};       /*   存储执行的sql语句*/  

int DMDemo();

int main()
{
	DMDemo();
	system("pause");

	return 0;
}


int DMDemo()
{
  char strServerName[50];  
  char strUserName[50]; 
  char strPassword[50];  
  /*   设置服务器,用户名和密码  */  
  strcpy(strServerName,"localhost");  
  strcpy(strUserName,"SYSDBA");  
  strcpy(strPassword,"111111"); //SYSDBA
  /* 初始化OCI应用环境*/  
  OCIInitialize(OCI_DEFAULT, NULL, NULL, NULL, NULL); 
  /* 初始化环境句柄  */  
  OCIEnvInit(&envhp, OCI_DEFAULT,0, 0); 
  /*  分配句柄    */  
  OCIHandleAlloc(envhp, (dvoid**)&svchp, OCI_HTYPE_SVCCTX, 0, 0);    /*   服务器环境句
柄    */    
  OCIHandleAlloc(envhp, (dvoid**)&srvhp, OCI_HTYPE_SERVER, 0, 0);    /*   服务器句柄
    */  
  OCIHandleAlloc(envhp, (dvoid**)&authp, OCI_HTYPE_SESSION, 0, 0);  /*   会话句柄    */  
  OCIHandleAlloc(envhp, (dvoid**)&errhp, OCI_HTYPE_ERROR, 0, 0);    /*   错误句柄 */  
  OCIHandleAlloc(envhp, (dvoid**)&dschp, OCI_HTYPE_DESCRIBE,0,0);    /*   描述符句柄    */  
  /*   连接服务器    */  
  OCIServerAttach(srvhp, errhp,(text *)strServerName,   
    (sb4)strlen(strServerName),OCI_DEFAULT ) ;  
  /*   设置用户名和密码  */  
  OCIAttrSet(authp,OCI_HTYPE_SESSION,(text *)strUserName,  
    (ub4)strlen(strUserName),OCI_ATTR_USERNAME,errhp);  
  OCIAttrSet(authp,OCI_HTYPE_SESSION,(text *)strPassword, 
    (ub4)strlen(strPassword), OCI_ATTR_PASSWORD,errhp);  
  /*   设置服务器环境句柄属性  */  
  OCIAttrSet ((dvoid*)svchp, (ub4) OCI_HTYPE_SVCCTX,   
    (dvoid*)srvhp, (ub4) 0, OCI_ATTR_SERVER, errhp);  
  OCIAttrSet(svchp, OCI_HTYPE_SVCCTX,(dvoid*)authp,   
    0, OCI_ATTR_SESSION, errhp); 
  /*   创建并开始一个用户会话  */  
  OCISessionBegin (svchp, errhp, authp,OCI_CRED_RDBMS,OCI_DEFAULT); 
  OCIHandleAlloc(envhp, (dvoid**)&stmthp,OCI_HTYPE_STMT, 0, 0);    /*   语句句柄   */  
  /************************************************************************/ 
  /* 查询person 表                                                         */  
  /************************************************************************/  
  strcpy(sql, "select personid, name, phone from person.person;");  
  /*   准备SQL 语句    */  
  OCIStmtPrepare(stmthp, errhp,(text *)sql, strlen(sql),OCI_NTV_SYNTAX, OCI_DEFAULT); 
  /*   绑定输出列    */  
  OCIDefineByPos(stmthp,&defhp[0],errhp, 1,(ub1*)szpersonid, 
      sizeof(szpersonid),SQLT_STR,&ind[0], 0, 0, OCI_DEFAULT); 
  OCIDefineByPos (stmthp,&defhp[1],errhp, 2,(ub1*)szname, 
      sizeof(szname),SQLT_STR,&ind[1], 0, 0, OCI_DEFAULT);  
  OCIDefineByPos (stmthp,&defhp[ 2],errhp, 3,(ub1*)szphone,
	  sizeof(szphone),SQLT_STR,&ind[2], 0, 0, OCI_DEFAULT); 
  /*   执行SQL 语句    */  
  OCIStmtExecute(svchp, stmthp,errhp, (ub4)0, 0, NULL, NULL, OCI_DEFAULT);  
   
  printf("% -10s%-10s%-10s\n", "PERSONID", "NAME", "PHONE"); 
  while((OCIStmtFetch( stmthp, errhp,1,OCI_FETCH_NEXT,OCI_DEFAULT))!=OCI_NO_DATA)  
  {   
    printf("% -10s", szpersonid); 
    printf("% -10s", szname);  
    printf("% -10s\n", szphone);   
  } 
  /************************************************************************/ 
  /* 向person 表插入一条数据                                               */  
  /************************************************************************/ 
	  memset(sql, 0, sizeof(sql));  
	  strcpy(sql, "insert into person.person(sex, name, email, phone) values(:sex,:name,:email,:phone);"); 
	  /*   准备SQL 语句    */  
	  OCIStmtPrepare(stmthp, errhp,(text *)sql, strlen(sql),OCI_NTV_SYNTAX, OCI_DEFAULT); 
	  /*   绑定输入列    */ 
	  const OraText col_sex[] = ":sex";
	  const OraText col_name[] = ":name";
	  const OraText col_email[] = ":email";
	  const OraText col_phone[] = ":phone";

	  OCIBindByName(stmthp, &bidhp[0], errhp, col_sex, 4, szsex, sizeof(szsex),SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	  OCIBindByName(stmthp, &bidhp[1], errhp, col_name, 5, szname, sizeof(szname), SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	  OCIBindByName(stmthp, &bidhp[2], errhp, col_email, 6, szemail, sizeof(szemail),SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	  OCIBindByName(stmthp, &bidhp[3], errhp, col_phone, 6, szphone, sizeof(szphone),SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	
	//OCIBindByName(stmthp, &bidhp[0], errhp, ":sex", 4, szsex, sizeof(szsex),SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	//OCIBindByName(stmthp, &bidhp[1], errhp, ":name", 5, szname, sizeof(szname), SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	//OCIBindByName (stmthp, &bidhp[2], errhp, ":email", 6, szemail, sizeof(szemail),SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	//OCIBindByName (stmthp, &bidhp[3], errhp, ":phone", 6, szphone, sizeof(szphone),SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  

	/*   设置输入参数  */  
	memset(szsex, 0, sizeof(szsex)); 
	//strcpy(szsex, "M");  
	memcpy(szsex,"M",strlen("M")+1);

	memset(szname, 0, sizeof(szname)); 
	//strcpy(szname, " 张三");  
	memcpy(szname,"张三",strlen("张三")+1);

	memset(szemail, 0, sizeof(szemail)); 
	//strcpy(szemail, "zhangsan@dameng.com");  
	memcpy(szemail,"zhangsan@dameng.com",strlen("zhangsan@dameng.com")+1);

	memset(szphone, 0, sizeof(szphone));  
	memcpy(szphone,"027-87588000",strlen("027-87588000")+1);
	//strcpy(szphone, "027-87588000");  


	/*   执行SQL 语句    */  
	  OCIStmtExecute(svchp, stmthp, errhp, (ub4)0, (ub4) 0, (CONST OCISnapshot*) 0, (OCISnapshot*) 0,(ub4) OCI_DEFAULT);  
	  /*   提交到数据库  */ 
	  OCITransCommit(svchp, errhp, OCI_DEFAULT);  
	  /************************************************************************/ 
	  /* 更新person 表                         */  
	  /************************************************************************/ 
	  memset(sql, 0, sizeof(sql));  
	  strcpy(sql, "update person.person set sex=&#39;M&#39;,name=&#39;Liuhuan&#39;,email=&#39;liujian@mail&#39;,phone=&#39;13636396811&#39; WHERE personid=1");  
	  /*   准备SQL 语句    */  
	  OCIStmtPrepare(stmthp, errhp,(text *)sql, strlen(sql),OCI_NTV_SYNTAX, OCI_DEFAULT); 
	  /*   执行SQL 语句    */  
	  OCIStmtExecute (svchp, stmthp, errhp, (ub4)0, (ub4) 0, (CONST OCISnapshot*) 0, (OCISnapshot*) 0,(ub4) OCI_DEFAULT);  
	  /*   提交到数据库  */  
	  OCITransCommit(svchp, errhp, OCI_DEFAULT);  
	  /************************************************************************/ 
	  /* 删除person 表的ID为的数据,首先要在数据库中存在这条记录         */  
	  /************************************************************************/ 
	  memset(sql, 0, sizeof(sql));  
	  strcpy(sql, "delete from person.person WHERE personid=?");  
	  /*   准备SQL 语句    */  
	  OCIStmtPrepare(stmthp, errhp,(text *)sql, strlen(sql),OCI_NTV_SYNTAX, OCI_DEFAULT);  
	  /*   绑定输入参数  */  
	  memset(szpersonid, 0, sizeof(szpersonid));  
	  memcpy(szpersonid,"20",strlen("20")+1);
	  //strcpy(szpersonid, "20"); 

	  OCIBindByPos(stmthp, &bidhp[0], errhp, 1, szpersonid, sizeof(szpersonid),SQLT_AFC, NULL, NULL, NULL, 0, NULL, 0);  
	  /*   执行SQL 语句    */  
	  OCIStmtExecute(svchp, stmthp, errhp, (ub4)0, (ub4) 0, (CONST OCISnapshot*) 0, (OCISnapshot*) 0, (ub4) OCI_DEFAULT);  
	  /*   提交到数据库  */  
	  OCITransCommit(svchp, errhp, OCI_DEFAULT);  
	  // 结束会话 
	  OCISessionEnd(svchp, errhp, authp, (ub4) 0); 
	  // 断开与数据库的连接 
	  OCIServerDetach(srvhp, errhp, OCI_DEFAULT);  
	  // 释放OCI句柄  
	  OCIHandleFree((dvoid*)dschp, OCI_HTYPE_DESCRIBE); 
	  OCIHandleFree((dvoid*)stmthp, OCI_HTYPE_STMT ); 
	  OCIHandleFree((dvoid*)errhp, OCI_HTYPE_ERROR); 
	  OCIHandleFree((dvoid*)authp, OCI_HTYPE_SESSION ); 
	  OCIHandleFree(( dvoid*)svchp, OCI_HTYPE_SVCCTX); 
	  OCIHandleFree((dvoid*)srvhp, OCI_HTYPE_SERVER);  
	  return 0;  
  }
声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
mysql:blob和其他无-SQL存储,有什么区别?mysql:blob和其他无-SQL存储,有什么区别?May 13, 2025 am 12:14 AM

mysql'sblobissuitableForStoringBinaryDataWithInareLationalDatabase,而alenosqloptionslikemongodb,redis和calablesolutionsoluntionsoluntionsoluntionsolundortionsolunsolunsstructureddata.blobobobsimplobissimplobisslowderperformandperformanceperformancewithlararengelitiate;

mySQL添加用户:语法,选项和安全性最佳实践mySQL添加用户:语法,选项和安全性最佳实践May 13, 2025 am 12:12 AM

toaddauserinmysql,使用:createUser'username'@'host'Indessify'password'; there'showtodoitsecurely:1)choosethehostcarecarefullytocon trolaccess.2)setResourcelimitswithoptionslikemax_queries_per_hour.3)usestrong,iniquepasswords.4)Enforcessl/tlsconnectionswith

MySQL:如何避免字符串数据类型常见错误?MySQL:如何避免字符串数据类型常见错误?May 13, 2025 am 12:09 AM

toAvoidCommonMistakeswithStringDatatatPesInMysQl,CloseStringTypenuances,chosethirtightType,andManageEngencodingAndCollat​​ionsEttingsefectery.1)usecharforfixed lengengters lengengtings,varchar forbariaible lengength,varchariable length,andtext/blobforlabforlargerdata.2 seterters seterters seterters seterters

mySQL:字符串数据类型和枚举?mySQL:字符串数据类型和枚举?May 13, 2025 am 12:05 AM

mysqloffersechar,varchar,text,and denumforstringdata.usecharforfixed Lengttrings,varcharerforvariable长度,文本forlarger文本,andenumforenforcingDataAntegrityWithaEtofValues。

mysql blob:如何优化斑点请求mysql blob:如何优化斑点请求May 13, 2025 am 12:03 AM

优化MySQLBLOB请求可以通过以下策略:1.减少BLOB查询频率,使用独立请求或延迟加载;2.选择合适的BLOB类型(如TINYBLOB);3.将BLOB数据分离到单独表中;4.在应用层压缩BLOB数据;5.对BLOB元数据建立索引。这些方法结合实际应用中的监控、缓存和数据分片,可以有效提升性能。

将用户添加到MySQL:完整的教程将用户添加到MySQL:完整的教程May 12, 2025 am 12:14 AM

掌握添加MySQL用户的方法对于数据库管理员和开发者至关重要,因为它确保数据库的安全性和访问控制。1)使用CREATEUSER命令创建新用户,2)通过GRANT命令分配权限,3)使用FLUSHPRIVILEGES确保权限生效,4)定期审计和清理用户账户以维护性能和安全。

掌握mySQL字符串数据类型:varchar vs.文本与char掌握mySQL字符串数据类型:varchar vs.文本与charMay 12, 2025 am 12:12 AM

chosecharforfixed-lengthdata,varcharforvariable-lengthdata,andtextforlargetextfield.1)chariseffity forconsistent-lengthdatalikecodes.2)varcharsuitsvariable-lengthdatalikenames,ballancingflexibilitibility andperformance.3)

MySQL:字符串数据类型和索引:最佳实践MySQL:字符串数据类型和索引:最佳实践May 12, 2025 am 12:11 AM

在MySQL中处理字符串数据类型和索引的最佳实践包括:1)选择合适的字符串类型,如CHAR用于固定长度,VARCHAR用于可变长度,TEXT用于大文本;2)谨慎索引,避免过度索引,针对常用查询创建索引;3)使用前缀索引和全文索引优化长字符串搜索;4)定期监控和优化索引,保持索引小巧高效。通过这些方法,可以在读取和写入性能之间取得平衡,提升数据库效率。

See all articles

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

Video Face Swap

Video Face Swap

使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热门文章

热工具

EditPlus 中文破解版

EditPlus 中文破解版

体积小,语法高亮,不支持代码提示功能

PhpStorm Mac 版本

PhpStorm Mac 版本

最新(2018.2.1 )专业的PHP集成开发工具

SublimeText3 Linux新版

SublimeText3 Linux新版

SublimeText3 Linux最新版

WebStorm Mac版

WebStorm Mac版

好用的JavaScript开发工具

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

功能强大的PHP集成开发环境