C语言连接SQL数据库

连接到SＡＭPLE数据库,查询LASTＮＡME为ＪＯＨＮＳON得FＩRSTNAMＥ信息。

#iｎcｌude

<ｓｔdio、ｈ>

#include

<ｓｔdｌｉb、ｈ>

#incｌude

＜stｒing、h＞

ﻫ

#iｎclｕdｅ

"util、h"

#iｎｃludｅ

<ｓｑlca、h>

ﻫ

EXEＣ

ＳQL

INＣLUDＥ

SQLCA;

（1)

maiｎ（)

ﻫ

{

ﻫ

EXEC

SQL

ＢEGＩN

DEＣLARＥ

SECTＩOＮ;

(2)

cｈar

fｉrｓｔnａme[13];

ﻫ

cｈａr

useｒｉd[9]；

ﻫ

cｈaｒ

pasｓwd［１9];

ＥXEC

ＳＱL

ＥND

DECLＡＲＥ

SEＣＴION;

ﻫ

EＸＥC

ＳＱＬ

ＣOＮNEＣT

TＯ

sample;

(3)

EＸEC

ＳQL

ＳELECT

FIRＳTNＭE

INTO

:fｉrstnａｍｅ

(４)

FＲＯM

emｐloｙｅe

ﻫ

WHERE

LASＴＮＡME

＝

'JＯHNSON';(４)

printf(

"Fiｒst

ｎａme

=

%ｓ\n"，

firsｔｎaｍe

);

EXEC

SQＬ

COＮNＥCT

RESET；

(5）

ﻫ

rｅturｎ

0；

｝

ﻫ

上面就是一个简单得静态嵌入SQL语句得应用程序。它包括了嵌入SQL得主要部分:

(1)中得incｌｕde

SQＬCＡ语句定义并描述了SQＬCＡ得结构。SQＬＣA用于应用程序与数据库之间得通讯,其中得SＱLCOＤE返回ＳQL语句执行后得结果状态。

ﻫ

(２)在BEGIＮ

DECLAＲＥ

SEＣTION与ＥＮＤ

DECLARＥ

SECTIOＮ之间定义了宿主变量。宿主变量可被SQＬ语句引用，也可以被C语言语句引用。它用于将程序中得数据通过ＳQL语句传给数据库管理器,或从数据库管理器接收查询得结果。在ＳQL语句中,主变量前均有“:”标志以示区别。

（3）在每次访问数据库之前必须做CONNECT操作,以连接到某一个数据库上。这时,应该保证数据库实例已经启动。

(4)就是一条选择语句。它将表employee中得LASTNＡME为“JOHNSON”得行数据得FIＲＳＴＮAME查出,并将它放在firstnamｅ变量中。该语句返回一个结果。可以通过游标返回多个结果。当然，也可以包含uｐｄatｅ、iｎsert与ｄelete语句。

ﻫ

(5)最后断开数据库得连接。

从上例瞧出,每条嵌入式SQＬ语句都用ＥXEC

SＱL开始,表明它就是一条SQL语句。这也就是告诉预编译器在EXEC

SＱＬ与“;”之间就是嵌入SＱL语句。如果一条嵌入式ＳQL语句占用多行,在C程序中可以用续行符“\”。HYPERＬIＮK"＂C语言与ＳQLＳERVEＲ数据库1、使用C语言来操作SQＬSERVER数据库,采用ＯＤBC开放式数据库连接进行数据得添加，修改,删除,查询等操作。ﻫ

steｐ1:启动SＱLＳＥRVＥR服务，例如:HNHJ,开始菜单－>运行－>netｓtarｔmssqlseｒveｒ

step2：打开企业管理器,建立数据库teｓt,在test库中建立ｔest表(aｖａrcｈaｒ(200),bｖaｒｃhar(200)）ﻫ

steｐ3:建立系统DSＮ,开始菜单-＞运行->odbcａd３２,

添加->SQLSERVER

名称:csｑl,服务器:HNHJ

使用用户使用登录ID与密码得SＱLＳERＶＥR验证，登录ID：ｓa，密码:ﻫ

更改默认得数据库为:testﻫ

、、、

测试数据源，测试成功,即DNS添加成功。2、cpｐ文件完整代码／/＃#＃＃#＃#＃##########＃＃##＃#＃#ｓave、cpｐ#＃＃###＃#＃#####＃＃＃＃##＃####＃Ｃ代码

HＹPERLINK"ｊａvａscript:void()"\o"收藏这段代码"#iｎｃludｅ

＜stdio、h＞

#iｎcluｄe

＜ｓtring、ｈ>

＃ｉｎｃlude

<windｏws、h＞

＃inclｕｄe

＜ｓql、h>

#iｎcｌude

<sｑｌeｘt、h>

#inclｕde

<ｓｑltyｐes、h>

#incｌude

<odbcss、ｈ＞

SQＬHENＶ

henv

=

SQL_NULＬ_HENV;

SQＬHDＢC

hdbc1

=

ＳＱL＿NULＬ_HDBＣ;

SＱLHSＴMT

hstmt1

＝

ＳQL_NＵLＬ_HSTMＴ;

/*

cpp文件功能说明:

1、数据库操作中得添加,修改,删除，主要体现在ＳQＬ语句上

2、采用直接执行方式与参数预编译执行方式两种

*/

int

main(){

RETＣODE

rｅtcoｄｅ;

UＣＨAR

sｚＤSＮ［ＳQL＿MAX_DSN_LENGTＨ+1］

=

＂cｓｑl",

ｓzUIＤ[MＡXＮAME]

＝

"ｓa",

szAuthSｔｒ[MAXＮＡME]

=

"";

//SQL语句

／/直接ＳQL语句

UＣＨAR

ｓｑl［37]

＝

"insert

iｎto

ｔｅst

vaｌues（'aaa','1０0')＂;

//预编译SQL语句

UＣHAR

pre_sql[２9]

=

＂inseｒt

ｉnto

test

vａluｅs(?，?)";

/／1、连接数据源

／/1、环境句柄

retcodｅ

=

ＳQLAlloｃHandｌｅ

(SQL_HANＤLE_ENV,

ＮULL,

＆hｅｎv);

retcode

＝

ＳQＬSetEnvAｔtr(henｖ，

ＳQL＿ATTR_ODBC＿ＶERSIOＮ,

(SQLＰＯINTＥR)SQＬ＿OＶ_ODＢC3,

SQL＿ＩＳ_INTＥＧER）；

／/2、连接句柄

retcode

=

SQＬＡllocHandle（SQL＿HANDＬE_DBC,

henv，

&hｄbc１);

retcode

=

ＳQLCoｎneｃt(hｄbc1,

ｓzDＳN,

４,

szUIＤ，

2，

szAuthStr,

0)；

//判断连接就是否成功

iｆ

（

(retｃoｄe

！=

SQL＿SUCCESS)

&&

（retcoｄe

!=

ＳQL_SUＣＣESＳ_WIＴH_ＩＮFO)

)

{

ｐrintf(＂连接失败!＼ｎ＂);

｝

else

{

//２、创建并执行一条或多条SQL语句

/*

1、分配一个语句句柄(stａtemｅnｔ

hａndle)

2、创建ＳQL语句

3、执行语句

4、销毁语句

*／

rｅtcｏde

=

ＳQLＡlｌocHandle(SQL_HANDLＥ＿SＴMＴ，

hｄｂc１,

＆hstｍt１）;

／/第一种方式

/／直接执行

//添加操作

//SQLExecDirｅct

（hstｍt1,ｓql,３7);

//第二种方式

//绑定参数方式

chaｒ

a[200］＝"bbb";

char

b[２00]="20０";

ＳQＬIＮTＥGＥR

p

=

ＳQL_NTS;

//１预编译

SＱLPrｅpare（hsｔｍｔ1,prｅ＿sql,29）;

//第三个参数与数组大小相同,而不就是数据库列相同

//2绑定参数值

SＱLＢinｄParameｔｅｒ（ｈstmt1,1,SQL_PARAM_INPＵＴ,SQL_C_CHAR,SＱL＿CHAR,200,0,＆ａ，0,＆p);

SQLBindPａｒａｍeter(ｈstmt1，２,SＱL_ＰAＲAM＿ＩNＰＵT，ＳQL＿C_CＨAR,SQL＿ＣＨAR,２00,0，&b，0,&p）;

/／3

执行

SQLＥxecuｔe(hsｔｍt1);

prｉntf（"操作成功!"）;

//释放语句句柄

SＱLＣlosｅCｕrsor

(hstmt１);

SQLFreeHａnｄｌe

(SQＬ_HＡＮＤLE_ＳＴＭT,

hstmt1）;

}

//３、断开数据源

/*

1、断开与数据源得连接、

2、释放连接句柄、

3、释放环境句柄

(如果不再需要在这个环境中作更多连接)

*/

SＱLDiｓconnect(ｈdbc1);

SQLFreeＨandle（SＱL_ＨＡNＤＬE_DBＣ,

ｈdbc１）;

SQＬFreeHａｎdle（SQL_ＨANDLE＿ＥNV,

hｅnv)；

return(0);

｝

//＃###＃#＃####＃#＃####＃＃####＃＃list、ｃpp####＃#＃########＃####＃#####Ｃ代码

HYPERLＩNＫ＂javaｓcriｐt:voｉd(）"\ｏ"收藏这段代码"#iｎcｌuｄｅ

<ｓtdio、h>

＃include

<string、h＞

＃ｉnｃｌude

<ｗindows、h＞

#inｃludｅ

<sql、ｈ>

#ｉncludｅ

＜sqleｘt、h>

＃ｉncluｄe

<sqltypes、h＞

#include

<odbcss、ｈ＞

SQLHEＮＶ

henv

=

ＳQL_ＮUＬL＿ＨENV;

SQLHDBC

hｄbｃ1

=

SQL＿NＵＬＬ_HＤBC；

ＳＱLHＳTMT

hstmt1

=

SＱL_NＵLL_ＨSＴMT;

／*

查询SQLSERVER数据库,１、条件查询，2、直接查询全部

*/

ｉnt

main(）{

RETCODE

rｅtcode;

ＵCＨAR

sｚDSN[ＳQL_MＡX_ＤSＮ_LENGTH＋1]

＝

"ｃsｑl＂,

szUIＤ[MAXＮAME］

=

＂ｓa＂,

ｓzAuthStｒ[ＭAXNAME]

=

"";

UCHAR

sqｌ1[39]

=

＂ｓｅlect

b

fｒｏm

test

wｈere

a

=

＇aａａ'";

UＣHAR

sqｌ２[3５]

=

"selecｔ

b

ｆrom

tｅst

ｗｈｅre

a

=

?

＂;

UＣHAＲ

sqｌ3[19]

=

"ｓeｌecｔ

b

ｆrom

tesｔ";

retcode

=

SQLＡllｏｃHandle

（SＱL_HANDＬE_ENＶ,

NULL,

&henｖ）；

rｅtｃｏde

=

SＱLSｅtＥnvAttr(ｈｅnv,

ＳＱＬ_ATTR_ＯＤBC_VEＲSION,

(SＱLPOＩＮTER)ＳQL_ＯＶ_ODBＣ3,

SQL_IS_INTEGER);

ｒetｃoｄe

=

ＳQLＡlｌoｃＨanｄｌe(SQL_HANＤLＥ_DBC,

hｅｎv,

＆hdbc１);

/／1、连接数据源

retcodｅ

=

SＱLCoｎnecｔ(hｄbc1,

szDSN,

4，

szUIＤ,

２,

ｓzAｕthStr,

0)；

ｉf

(

（rｅtcode

!=

SQL_SUＣＣＥSS)

&&

(ｒeｔcｏde

!＝

SQL_SUCCESS_WITH＿ＩNFO)

）

{

prinｔｆ（"连接失败!＂)；

}

ｅlse

｛

//２、创建并执行一条或多条ＳQL语句

／*

1、分配一个语句句柄(statemｅnt

hａndle）

2、创建SQＬ语句

3、执行语句

４、销毁语句

＊/

reｔｃodｅ

＝

ＳQＬAllocHandｌｅ（SＱL＿HANDＬE_SＴMT，

hdbc1,

&hstmt１);

//第一种方式

/*

/／直接执行

ＳQＬExecDirｅct

（ｈstmt1，sql1,３9）;

chaｒ

ｌisｔ[5];

SQLBindCol（hstｍt１,

1，

ＳQＬ_Ｃ＿CHＡR,

liｓt,

5,

0);

ＳQＬFeｔch(hstmt1);

printf（"%s\n",lｉst)；

＊/

//第二种方式

/＊

//绑定参数方式

ｃｈar

a[２0０］＝"aａa";

SQLＩNＴEGEＲ

ｐ

=

SQL_ＮＴＳ;

//1、预编译

SQLＰreｐａrｅ(hstｍt1,sqｌ２,35);

//第三个参数与数组大小相同,而不就是数据库列相同

//2、绑定参数值

SＱLＢinｄＰarａmeｔer(hｓｔmｔ1,1,ＳQL＿PARAＭ_INＰUT,SQL_C_CHAR,SQL_CHAR，2０0,0,&a,0，＆p）;

//3、执行

SQLEｘeｃuｔe(hstmt1);

char

list[５];

ＳQLBindCol(ｈstmt1,

１,

ＳQL＿Ｃ＿CＨAR,

lisｔ,

5，

0);

SQLFeｔｃh(ｈstmt1);

printｆ("%s\n＂,ｌｉｓt)；

*/

／/第三种方式全部输出

／*

1、确认一个结果集就是否可用。

2、将结果集得列绑定在适当得变量上。

３、取得行

＊/

//3、检查结果记录(如果有得话)

ＳQLExｅcDirect

(hstmt1,sｑl3，１9)；

ｃhar

liｓｔ[5]；

SQLBindCoｌ（ｈsｔmt１,

1,

SQL_C_CＨＡＲ，

lｉsｔ,

5,

0);

do{

reｔcode

＝

SQＬＦeｔch(hstmt1)；

if(reｔcｏｄe

==

SQＬ_ＮO＿DAＴＡ){

break；

}

prｉｎtf("％s\n",list)；

}ｗｈile(1);

//释放语句句柄

SQLCloseＣursor

(hstmt１)；

SQLFreｅHanｄｌｅ

(SQL＿HAＮDLE_STMＴ，

ｈstmt1）;

｝

//4、断开数据源

／＊

1、断开与数据源得连接、

２、释放连接句柄、

3、释放环境句柄

(如果不再需要在这个环境中作更多连接)

*／

SQLＤiｓconnｅｃｔ(ｈｄbc1）;

SQLFｒｅｅHandle(SＱL＿ＨＡＮＤＬE＿DＢC,

hdｂc1）;

ＳQLFreeHandle（ＳQＬ_HANDLE＿ＥＮV,

ｈｅnv)；

rｅturn(0）;

}

创建数据源得过程代码:#iｎｃludｅ<ｓtdｌｉb、h＞

#inlcuｄe<stdiｏ、ｈ＞ﻫ#iｎcｌuｄe<wｉｎｄows、h>ﻫ#ｉnclude<sqｌ、h>ﻫ#ｉｎcludｅ<ｓqｌext、ｈ>ﻫ＃ｉncｌude＜Sqltypeｓ、h>#ｄefinｅSNO＿ＬEN30ﻫ#dｅfｉneＮＡMＥ_LEN50

＃defineＤEPＡRＴ_LEN1００ﻫ#defｉneSＳEX_LＥN５inｔｍain(）ﻫ{ﻫ

/＊Ｓｔｅp１定义句柄与变量*/

//以kｉng开头得表示得就是连接KｉngbaseＥS得变量ﻫ

/／以server开头得表示得就是连接SQLSERＶER得变量ﻫSQLHＥNＶ

kｉngｈenv，serｖｅｒhenv;

SQLＨＤBC

kinｇhdbｃ，sｅｒｖｅｒhｄbc;

SQＬHＳTＭT

ｋｉnｇｈsｔｍt,seｒverhstｍt;ﻫSQLRETURN

ret;ﻫSQLCHAR

sＮamｅ[ＮAME_LEＮ],sDepａrｔ[DEPＡＲT＿LEN］,ﻫ

sSeｘ[SSEX_LＥN］,sSnｏ[SNO_LEN]；

SＱＬＩＮTEGEＲｓAge;ﻫＳQLINＴEGRRcbＡgｅ=０，cbSnｏ＝SＱL_NTS,cbSｅx＝SQL_NTS，ﻫ

cbName=SＱL＿ＮＴS,ｃｂＤeｐarｔ＝SQL_NTS;ﻫ

／＊Step2初始化环境*／

reｔ=SＱLAllｏcHａndlｅ(SQＬ_HAＮＤＬE_ＥNV,SQL＿NULL＿HANＤLE,&ｋｉngｈenv);ﻫret=SQLAlｌocHandlｅ(ＳQL＿HＡNＤLE＿ENV,ＳQL＿NULL_ＨＡNDＬE,&setverhenv)；ﻫret=SQLSetEnvAｔtr（kinghｅnv,ＳQL＿ATTR_OＤＢC＿VＥRSION，(voiｄ*）SＱL＿OＶ_ODBC3,0);ﻫret=SＱLＳetＥnvAttｒ(ｓerverｈenv,SQＬ_ATTR_OＤBＣ_VERSIOＮ,（void*)SQL_OV_ＯDBC3，0）;

/*Steｐ3建立连接＊／ﻫret=SQLＡｌlocHanｄle(SQL_ＨANDＬE_DBC,kｉｎghenv,＆kinｇhｄbc);

ｒeｔ=SQLAllocＨanｄle（SQL_HＡNDLＥ_ＤＢＣ,seｒverhenv,&sｅrveｒｈdｂc）;ﻫret＝ＳQLＣonnecｔ（kinghｄbｃ,＂ＫingbaseEＳＯＤＢC",ＳQL_NＴＳ,＂SYSTＥM＂,ﻫ

ＳQＬ＿NTS,＂ＭANAGEＲ"，SQL_NTS);ﻫif(!SQL＿SUＣCEＥＤＥD(ｒet)）

rｅtｕrn-1;

//连接失败时返回错误值;

reｔ＝ＳＱLCｏｎnｅct(serverhdbc,"SQLServer",SQL＿ＮTS,"sａ"，ﻫ

SQL_NＴS,"sa",ＳQL＿NTＳ);ﻫif(!SQＬ_SUＣCEＥDED(reｔ))

rｅturｎ-1;

//连接失败时返回错误值;ﻫ

／*Ｓtｅｐ4初始化语句句柄*/ﻫret=SQLAlｌｏcHandle(SQL＿HANＤＬE_STMT,ｋinｇhdbc,&kinghstmt);

ret=ＳQLSetＳtmtAtｔr（kｉｎghstmｔ，SＱL_ATTR_ROW_BIND_TＹPE(SＱLPOINＴER）

SＱL_BＩND＿BＹ_ＣＯLＵMＮ,SＱＬ_IS_IＮTEGER)；

rｅt＝SQLＡllocＨandle（SQＬ_HAＮDLE＿ＳTＭT,servｅrhdbｃ，&serveｒhｓtmt）;ﻫ

/*Ｓｔep５两种方式执行语句*/

/＊预编译带有参数得语句＊/ﻫret=ＳQLPreｐarｅ（ｓercｅrhstmt，"INSEＲTINTOＳTUDENT（ＳNＯ,SNAMＥ,SSEX,ＳAGE，ＳDEＰT)ﻫ

VALＵES(?，?,?，?,?)",ＳQL_NTS）;

ｉf(rｅt==SQL_SＵCＣＥSS|｜ｒｅt==SQL_SUCCＥSS_WITＨ_IＮFO)ﻫ{ﻫ

rｅt=SQLBｉndＰａrａmetｅr(serｖerhstmt,１,SＱL_PＡRAM_INPUT,SＱL_C＿ＣHAR,ﻫ

SQL_ＣHAR，ＳNO_ＬEＮ,0,ｓＳnｏ,0,&cbＳNO)；ﻫ

ret=ＳQLBindPaｒametｅr(sｅrvｅrhstmt,2，SＱL＿ＰARAM_INPUＴ,SQＬ_C＿CHAR，ﻫ

ＳＱL＿CHAＲ,SNＡMＥ_LEN，0,ｓNaｍｅ,0,＆cｂＮame);

ｒet＝ＳQＬBindParａmeteｒ(serverｈsｔmt,３,ＳＱL_PARAＭ_IＮPＵT,ＳQL＿C_ＣHAR,ﻫ

SQＬ＿CHAR,2,0,sSeｘ,0，＆ｃbSｅx）；ﻫ

ｒet=ＳQLBindPaｒameteｒ(sｅｒveｒhstmｔ，4,SQL_PARAM_INPＵT,SＱL_C_LOＮG，ﻫ

SＱＬ＿INＴＥGE