SocketMySql总结.doc

MySQL是一个多用户、多线程的SQL数据库，是一个客户机/服务器结构的应用，它由一个服务器守护程序mysqld和很多不同的客户程序和库组成。套接字是通信双方一种相互约定的通信方式和规则，在TCP/IP通信中，一般使用套接字的相关函数接口来完成通信过程。Windows Sockets规范定义了应用程序开发者能够使用，并且网络软件供应商能够实现的一套库函数调用和相关语义，基于Windows Sockets的应用开发中主要应用的是WinSock API编程。Windows Sockets API是Win32 API的一个子集，是在TCP/IP网络环境里，也是Internet上进行开发最为通用的API。在网络通信环境中，Socket的数据通信可以看成是类似于C+中的一种特殊的I/O输入输出流，也就是一种文件描述符号，它在网络通信中使用一个Socket()函数对应于文件打开的Open()函数。Socket是一个通信端点，是网络通信程序设计的一个端口，通过这个端口，网络应用程序可以通过公共网络和其他网络应用程序进行通信。 在VC中进行WinSock的API网络应用程序开发，需要使用到以下三个文件： WinSock.h：这是WinSock API的头文件。 Wsock32.lib：WinSock API链接库文件。 WinSock.dll：WinSock的动态链接库文件。 VC的MFC库为TCP/IP网络应用程序提供了两个类： CAsyncSocket类：CAsyncSocket继承于CObject类，它提供基于异步通信的套接字封装功能。 CSocket：CSocket则是由CAsyncSocket派生，提供更加高层次的功能，例如可以将套接字上发送和接收的数据和一个文件对象(CSocketFile)关联起来，通过读写文件来达到发送和接收数据的目的，而且CSocket提供的通信为同步通信，数据未接收到或是未发送完之前调用不会返回。 什么是C/S模式？ C/S（Client/Server）结构，即客户机和服务器结构。它是一种软件系统体系结构，这种软件系统体系结构可以充分利用网络分布式计算资源，将任务（存储、操作或计算的任务）合理分配到不同的客户端或服务器中，提高了软件维护和使用的方便性。 什么是B/S模式？ B/S（Browser/Server）结构即浏览器和服务器结构。它伴随着因特网的兴起而流行，是对客户机服务器模型的一种功能性改进的革命性跨越。一种是Stream Sockets（流格式）TCP，另外一种是Datagram Sockets（数据包格式）UDP。SOCK_STREAM 和 SOCK_DGRAM。数据报套接字有时也叫“无连接套接字”struct sockaddr unsigned short sa_family; /* 地址家族, AF_xxx */ char sa_data14; /*14字节协议地址*/ ; AF_INET。 sa_data包含套接字中的目标地址和端口信息。short int sin_family; /* 通信类型 */ unsigned short int sin_port; /* 端口 */ struct in_addr sin_addr; /* Internet 地址 */ unsigned char sin_zero8; /* 与sockaddr结构的长度相同*/htons() (Host to Network Short)。int socket(int domain, int type, int protocol);domain 应该设置成 AF_INET，就 象上面的数据结构struct sockaddr_in 中一样。然后，参数 type 告诉内核 是 SOCK_STREAM 类型还是 SOCK_DGRAM 类型。最后，把 protocol 设置为 0。int bind(int sockfd, struct sockaddr *my_addr, int addrlen); sockfd 是调用 socket 返回的文件描述符。my_addr 是指向数据结构 struct sockaddr 的指针，它保存你的地址(即端口和 IP 地址) 信息。 addrlen 设置为 sizeof(struct sockaddr)。 不要采用小于 1024的端口号。所有小于1024的端口号都被系统保留！你可以选择从1024 到65535的端口(如果它们没有被别的程序使用的话)。 通过端口 23(标准 telnet 端口)连接到0int connect(int sockfd, struct sockaddr *serv_addr, int addrlen); sockfd 是系统调用 socket() 返回的套接字文件描述符。serv_addr 是 保存着目的地端口和 IP 地址的数据结构 struct sockaddr。addrlen 设置 为 sizeof(struct sockaddr)。 #define DEST_IP 0 #define DEST_PORT 23 main() int sockfd; struct sockaddr_in dest_addr; /* 目的地址*/ sockfd = socket(AF_INET, SOCK_STREAM, 0); /* 错误检查 */ dest_addr.sin_family = AF_INET; /* host byte order */ dest_addr.sin_port = htons(DEST_PORT); /* short, network byte order */ dest_addr.sin_addr.s_addr = inet_addr(DEST_IP); bzero(&(dest_addr.sin_zero),; /* zero the rest of the struct */ /* dont forget to error check the connect()! */ connect(sockfd, (struct sockaddr *)&dest_addr, sizeof(struct sockaddr);accept（）：int listen(int sockfd, int backlog); sockfd 是调用 socket() 返回的套接字文件描述符。backlog 是在进入 队列中允许的连接数目（20,5-10）。send() and recv()函数 这两个函数用于流式套接字或者数据报套接字的通讯int send(int sockfd, const void *msg, int len, int flags); sockfd 是你想发送数据的套接字描述符(或者是调用 socket() 或者是 accept() 返回的。)msg 是指向你想发送的数据的指针。len 是数据的长度。 把 flags 设置为 0 就可以了。它在错误的时候返回-1，并设置 errno。 int recv(int sockfd, void *buf, int len, unsigned int flags); sockfd 是要读的套接字描述符。buf 是要读的信息的缓冲。len 是缓 冲的最大长度。flags 可以设置为0。(请参考recv() 的 man page。) recv() 返回实际读入缓冲的数据的字节数。或者在错误的时候返回-1， 同时设置 errno。 一、WSAStartup函数 int WSAStartup( WORD wVersionRequested, LPWSADATA lpWSAData ); 使用Socket的程序在使用Socket之前必须调用WSAStartup函数。该函数的第一个参数指明程序请求使用的Socket版本，其中高位字节指明副版本、低位字节指明主版本；操作系统利用第二个参数返回请求的Socket的版本信息。当一个应用程序调用WSAStartup函数时，操作系统根据请求的Socket版本来搜索相应的Socket库，然后绑定找到的Socket库到该应用程序中。以后应用程序就可以调用所请求的Socket库中的其它Socket函数了。该函数执行成功后返回0。 例：假如一个程序要使用2.1版本的Socket,那么程序代码如下 wVersionRequested = MAKEWORD( 2, 1 ); err = WSAStartup( wVersionRequested, &wsaData ); 二、WSACleanup函数 int WSACleanup (void); 应用程序在完成对请求的Socket库的使用后，要调用WSACleanup函数来解除与Socket库的绑定并且释放Socket库所占用的系统资源。 三、socket函数 SOCKET socket( int af, int type, int protocol ); 应用程序调用socket函数来创建一个能够进行网络通信的套接字。第一个参数指定应用程序使用的通信协议的协议族，对于TCP/IP协议族，该参数置PF_INET;第二个参数指定要创建的套接字类型，流套接字类型为SOCK_STREAM、数据报套接字类型为SOCK_DGRAM；第三个参数指定应用程序所使用的通信协议。该函数如果调用成功就返回新创建的套接字的描述符，如果失败就返回INVALID_SOCKET。套接字描述符是一个整数类型的值。每个进程的进程空间里都有一个套接字描述符表，该表中存放着套接字描述符和套接字数据结构的对应关系。该表中有一个字段存放新创建的套接字的描述符，另一个字段存放套接字数据结构的地址，因此根据套接字描述符就可以找到其对应的套接字数据结构。每个进程在自己的进程空间里都有一个套接字描述符表但是套接字数据结构都是在操作系统的内核缓冲里。下面是一个创建流套接字的例子： struct protoent *ppe; ppe=getprotobyname(tcp); SOCKET ListenSocket=socket(PF_INET,SOCK_STREAM,ppe-p_proto);四、closesocket函数 int closesocket( SOCKET s ); closesocket函数用来关闭一个描述符为s套接字。由于每个进程中都有一个套接字描述符表，表中的每个套接字描述符都对应了一个位于操作系统缓冲区中的套接字数据结构，因此有可能有几个套接字描述符指向同一个套接字数据结构。套接字数据结构中专门有一个字段存放该结构的被引用次数，即有多少个套接字描述符指向该结构。当调用closesocket函数时，操作系统先检查套接字数据结构中的该字段的值，如果为1，就表明只有一个套接字描述符指向它，因此操作系统就先把s在套接字描述符表中对应的那条表项清除，并且释放s对应的套接字数据结构；如果该字段大于1，那么操作系统仅仅清除s在套接字描述符表中的对应表项，并且把s对应的套接字数据结构的引用次数减1。 closesocket函数如果执行成功就返回0，否则返回SOCKET_ERROR。 五、send函数 int send( SOCKET s, const char FAR *buf, int len, int flags ); 不论是客户还是服务器应用程序都用send函数来向TCP连接的另一端发送数据。客户程序一般用send函数向服务器发送请求，而服务器则通常用send函数来向客户程序发送应答。该函数的第一个参数指定发送端套接字描述符；第二个参数指明一个存放应用程序要发送数据的缓冲区；第三个参数指明实际要发送的数据的字节数；第四个参数一般置0。这里只描述同步Socket的send函数的执行流程。当调用该函数时，send先比较待发送数据的长度len和套接字s的发送缓冲区的长度，如果len大于s的发送缓冲区的长度，该函数返回SOCKET_ERROR；如果len小于或者等于s的发送缓冲区的长度，那么send先检查协议是否正在发送s的发送缓冲中的数据，如果是就等待协议把数据发送完，如果协议还没有开始发送s的发送缓冲中的数据或者s的发送缓冲中没有数据，那么send就比较s的发送缓冲区的剩余空间和len，如果len大于剩余空间大小send就一直等待协议把s的发送缓冲中的数据发送完，如果len小于剩余空间大小send就仅仅把buf中的数据copy到剩余空间里（注意并不是send把s的发送缓冲中的数据传到连接的另一端的，而是协议传的，send仅仅是把buf中的数据copy到s的发送缓冲区的剩余空间里）。如果send函数copy数据成功，就返回实际copy的字节数，如果send在copy数据时出现错误，那么send就返回SOCKET_ERROR；如果send在等待协议传送数据时网络断开的话，那么send函数也返回SOCKET_ERROR。要注意send函数把buf中的数据成功copy到s的发送缓冲的剩余空间里后它就返回了，但是此时这些数据并不一定马上被传到连接的另一端。如果协议在后续的传送过程中出现网络错误的话，那么下一个Socket函数就会返回SOCKET_ERROR。（每一个除send外的Socket函数在执行的最开始总要先等待套接字的发送缓冲中的数据被协议传送完毕才能继续，如果在等待时出现网络错误，那么该Socket函数就返回SOCKET_ERROR） 注意：在Unix系统下，如果send在等待协议传送数据时网络断开的话，调用send的进程会接收到一个SIGPIPE信号，进程对该信号的默认处理是进程终止。 六、recv函数 int recv( SOCKET s, char FAR *buf, int len, int flags ); 不论是客户还是服务器应用程序都用recv函数从TCP连接的另一端接收数据。该函数的第一个参数指定接收端套接字描述符；第二个参数指明一个缓冲区，该缓冲区用来存放recv函数接收到的数据；第三个参数指明buf的长度；第四个参数一般置0。这里只描述同步Socket的recv函数的执行流程。当应用程序调用recv函数时，recv先等待s的发送缓冲中的数据被协议传送完毕，如果协议在传送s的发送缓冲中的数据时出现网络错误，那么recv函数返回SOCKET_ERROR，如果s的发送缓冲中没有数据或者数据被协议成功发送完毕后，recv先检查套接字s的接收缓冲区，如果s接收缓冲区中没有数据或者协议正在接收数据，那么recv就一直等待，只到协议把数据接收完毕。当协议把数据接收完毕，recv函数就把s的接收缓冲中的数据copy到buf中（注意协议接收到的数据可能大于buf的长度，所以在这种情况下要调用几次recv函数才能把s的接收缓冲中的数据copy完。recv函数仅仅是copy数据，真正的接收数据是协议来完成的），recv函数返回其实际copy的字节数。如果recv在copy时出错，那么它返回SOCKET_ERROR；如果recv函数在等待协议接收数据时网络中断了，那么它返回0。 注意：在Unix系统下，如果recv函数在等待协议接收数据时网络断开了，那么调用recv的进程会接收到一个SIGPIPE信号，进程对该信号的默认处理是进程终止。 七、bind函数 int bind( SOCKET s, const struct sockaddr FAR *name, int namelen ); 当创建了一个Socket以后，套接字数据结构中有一个默认的IP地址和默认的端口号。一个服务程序必须调用bind函数来给其绑定一个IP地址和一个特定的端口号。客户程序一般不必调用bind函数来为其Socket绑定IP地址和断口号。该函数的第一个参数指定待绑定的Socket描述符；第二个参数指定一个sockaddr结构，该结构是这样定义的： struct sockaddr u_short sa_family; char sa_data14; ; sa_family指定地址族，对于TCP/IP协议族的套接字，给其置AF_INET。当对TCP/IP协议族的套接字进行绑定时，我们通常使用另一个地址结构： struct sockaddr_in short sin_family; u_short sin_port; struct in_addr sin_addr; char sin_zero8; ; 其中sin_family置AF_INET；sin_port指明端口号；sin_addr结构体中只有一个唯一的字段s_addr，表示IP地址，该字段是一个整数，一般用函数inet_addr（）把字符串形式的IP地址转换成unsigned long型的整数值后再置给s_addr。有的服务器是多宿主机，至少有两个网卡，那么运行在这样的服务器上的服务程序在为其Socket绑定IP地址时可以把htonl(INADDR_ANY)置给s_addr，这样做的好处是不论哪个网段上的客户程序都能与该服务程序通信；如果只给运行在多宿主机上的服务程序的Socket绑定一个固定的IP地址，那么就只有与该IP地址处于同一个网段上的客户程序才能与该服务程序通信。我们用0来填充sin_zero数组，目的是让sockaddr_in结构的大小与sockaddr结构的大小一致。下面是一个bind函数调用的例子： struct sockaddr_in saddr； saddr.sin_family = AF_INET; saddr.sin_port = htons(8888); saddr.sin_addr.s_addr = htonl(INADDR_ANY); bind(ListenSocket,(struct sockaddr *)&saddr,sizeof(saddr)； 八、listen函数 int listen( SOCKET s, int backlog ); 服务程序可以调用listen函数使其流套接字s处于监听状态。处于监听状态的流套接字s将维护一个客户连接请求队列，该队列最多容纳backlog个客户连接请求。假如该函数执行成功，则返回0；如果执行失败，则返回SOCKET_ERROR。 九、accept函数 SOCKET accept( SOCKET s, struct sockaddr FAR *addr, int FAR *addrlen ); 服务程序调用accept函数从处于监听状态的流套接字s的客户连接请求队列中取出排在最前的一个客户请求，并且创建一个新的套接字来与客户套接字创建连接通道，如果连接成功，就返回新创建的套接字的描述符，以后与客户套接字交换数据的是新创建的套接字；如果失败就返回INVALID_SOCKET。该函数的第一个参数指定处于监听状态的流套接字；操作系统利用第二个参数来返回新创建的套接字的地址结构；操作系统利用第三个参数来返回新创建的套接字的地址结构的长度。下面是一个调用accept的例子： struct sockaddr_in ServerSocketAddr; int addrlen; addrlen=sizeof(ServerSocketAddr); ServerSocket=accept(ListenSocket,(struct sockaddr *)&ServerSocketAddr,&addrlen); int accept(int sockfd, void *addr, int *addrlen); sockfd 相当简单，是和 listen() 中一样的套接字描述符。addr 是个指 向局部的数据结构 sockaddr_in 的指针。这是要求接入的信息所要去的地 方（你可以测定那个地址在那个端口呼叫你）。在它的地址传递给 accept 之 前，addrlen 是个局部的整形变量，设置为 sizeof(struct sockaddr_in)。 accept 将不会将多余的字节给 addr。如果你放入的少些，那么它会通过改变 addrlen 的值反映出来。 同样，在错误时返回-1，并设置全局错误变量 errno。 十、connect函数 int connect( SOCKET s, const struct sockaddr FAR *name, int namelen ); 客户程序调用connect函数来使客户Socket s与监听于name所指定的计算机的特定端口上的服务Socket进行连接。如果连接成功，connect返回0；如果失败则返回SOCKET_ERROR。下面是一个例子： struct sockaddr_in daddr; memset(void *)&daddr,0,sizeof(daddr); daddr.sin_family=AF_INET; daddr.sin_port=htons(8888); daddr.sin_addr.s_addr=inet_addr(); connect(ClientSocket,(struct sockaddr *)&daddr,sizeof(daddr)； sockets（套接字）编程有三种，流式套接字（SOCK_STREAM），数据报套接字（SOCK_DGRAM），原始套接字（SOCK_RAW）；基于TCP的socket编程是采用的流式套接字。在这个程序中，将两个工程添加到一个工作区。要链接一个ws2_32.lib的库文件。1：加载套接字库，创建套接字(WSAStartup()/socket()2：绑定套接字到一个IP地址和一个端口上(bind()；3：将套接字设置为监听模式等待连接请求(listen()； 4：请求到来后，接受连接请求，返回一个新的对应于此次连接的套接字(accept()； 5：用返回的套接字和客户端进行通信(send()/recv()；6：返回，等待另一连接请求； 7：关闭套接字，关闭加载的套接字库(closesocket()/WSACleanup()。客户端编程的步骤：1：加载套接字库，创建套接字(WSAStartup()/socket()；2：向服务器发出连接请求(connect()；3：和服务器端进行通信(send()/recv()4：关闭套接字，关闭加载的套接字库(closesocket()/WSACleanup()。网络上的两个程序通过一个双向的通讯连接实现数据的交换，这个双向链路的一端称为一个Socket。Socket通常用来实现客户方和服务方的连接。Socket是TCP/IP协议的一个十分流行的编程界面，一个Socket由一个IP地址和一个端口号唯一确定。socket()我们使用系统调用socket()来获得文件描述符：#include#includeint socket(int domain,int type,int protocol);第一个参数domain设置为“AF_INET”。第二个参数是套接口的类型：SOCK_STREAM或SOCK_DGRAM。第三个参数设置为0。系统调用socket()只返回一个套接口描述符，如果出错，则返回-1。bind()一旦你有了一个套接口以后，下一步就是把套接口绑定到本地计算机的某一个端口上。但如果你只想使用connect()则无此必要。下面是系统调用bind()的使用方法：#include#includeintbind(int sockfd,struct sockaddr*my_addr,int addrlen);第一个参数sockfd是由socket()调用返回的套接口文件描述符。第二个参数my_addr是指向数据结构sockaddr的指针。数据结构sockaddr中包括了关于你的地址、端口和IP地址的信息。第三个参数addrlen可以设置成sizeof(structsockaddr)。如果出错，bind()也返回-1。如果你使用connect()系统调用，那么你不必知道你使用的端口号。当你调用connect()时，它检查套接口是否已经绑定，如果没有，它将会分配一个空闲的端口。 connect()int connect(int sockfd,struct sockaddr* serv_addr,int addrlen);第一个参数还是套接口文件描述符，它是由系统调用socket()返回的。第二个参数是serv_addr是指向数据结构sockaddr的指针，其中包括目的端口和IP地址。第三个参数可以使用sizeof(structsockaddr)而获得。如果出错，connect()将会返回-1。listen()如果你希望不连接到远程的主机，也就是说你希望等待一个进入的连接请求，然后再处理它们。这样，你通过首先调用listen()，然后再调用accept()来实现。系统调用listen()的形式如下：intl isten(int sockfd,int backlog);第一个参数是系统调用socket()返回的套接口文件描述符。第二个参数是进入队列中允许的连接的个数。进入的连接请求在使用系统调用accept()应答之前要在进入队列中等待。这个值是队列中最多可以拥有的请求的个数。大多数系统的缺省设置为20。你可以设置为5或者10。当出错时，listen()将会返回-1值。当然，在使用系统调用listen()之前，我们需要调用bind()绑定到需要的端口，否则系统内核将会让我们监听一个随机的端口。所以，如果你希望监听一个端口，下面是应该使用的系统调用的顺序：socket();bind();listen();/*accept()goeshere*/accept()系统调用accept()比较起来有点复杂。在远程的主机可能试图使用connect()连接你使用listen()正在监听的端口。但此连接将会在队列中等待，直到使用accept()处理它。调用accept()之后，将会返回一个全新的套接口文件描述符来处理这个单个的连接。这样，对于同一个连接来说，你就有了两个文件描述符。原先的一个文件描述符正在监听你指定的端口，新的文件描述符可以用来调用send()和recv()。调用的例子如下：#includeintaccept(intsockfd,void*addr,int*addrlen);第一个参数是正在监听端口的套接口文件描述符。第二个参数addr是指向本地的数据结构sockaddr_in的指针。调用connect()中的信息将存储在这里。通过它你可以了解哪个主机在哪个端口呼叫你。第三个参数同样可以使用sizeof(structsockaddr_in)来获得。如果出错，accept()也将返回-1。send() 和recv()系统调用send()的用法如下：int send(int sockfd,const void* msg,int len,int flags);第一个参数是你希望给发送数据的套接口文件描述符。它可以是你通过socket()系统调用返回的，也可以是通过accept()系统调用得到的。第二个参数是指向你希望发送的数据的指针。第三个参数是数据的字节长度。第四个参数标志设置为0。系统调用send()返回实际发送的字节数，这可能比你实际想要发送的字节数少。如果返回的字节数比要发送的字节数少，你在以后必须发送剩下的数据。当send()出错时，将返回-1。系统调用recv()的使用方法和send()类似：int recv(int sockfd,void* buf,int len,unsigned int flags);第一个参数是要读取的套接口文件描述符。第二个参数是保存读入信息的地址。第三个参数是缓冲区的最大长度。第四个参数设置为0。系统调用recv()返回实际读取到缓冲区的字节数，如果出错则返回-1。这样使用上面的系统调用，你可以通过数据流套接口来发送和接受信息。1 MySQL数据库简介MySQL是一个真正的多用户、多线程SQL数据库服务器。SQL（结构化查询语言）是世界上最流行的和标准化的数据库语言，它使得存储、更新和存取信息更加容易。MySQL是一个客户机/服务器结构的实现，它由一个服务器守护程序mysqld和许多不同的客户程序以及库组成的。MySQL的主要目标是快速、健壮和易用。最初是因为MySQL的创始人需要这样的一个SQL服务器，它能处理与任何不昂贵硬件平台上提供数据库的厂家在一个数量级上的大型数据库，但速度更快，MySQL因此就开发出来了。它提供C，C+，JAVA(JDBC)，Perl，Python，PHP and TCL 的API接口；多平台支持，包括Solaris，SunOS，BSDI，SGI IRIX，AIX，DEC UNIX，Linux，FreeBSD，SCO OpenServer，NetBSD，OpenBSD，HPUX，Win9x and NT；多样的数据类型，包括有/无符号1，2，3，4，8字节integers，FLOAT，DOUBLE，CHAR，VARCHAR，TEXT，BLOB，DATE，DATETIME，YEAR，SET，ENUM；非常灵活和安全的权限系统，密码加密；为Windows提供ODBC接口，可通过Access与之相联，另有第三方开发商提供多样的 ODBC驱动程序；在MySQL 3.23中使用新MyISAM最大的表大小可达8百万 TB(263个字节)；多种语言支持，但不支持中文。然而，为了实现快速、健壮和易用的目的，MySQL必须牺牲一部分灵活而强大的功能，如子查询、存储过程与触发器、外键、事物处理等。因而，MySQL在某些应用中缺乏灵活性，但这也使它对数据的处理速度较其它数据库服务器至少快23倍。MySQL自身不支持Windows的图形界面，因此，所有的数据库操作及管理功能都只能在MS-DOS方式下完成。首先，必须登陆MySQL服务器，即在提示符MySQLBIN下输入MYSQL H host U user Ppassword，提示符改为mysql时表示登陆成功。然后，选择所操作的数据库，即mysql USE databasename。接着就可以用SQL语句进行查询了。如果需要退出数据库服务器，可执行QUIT命令，这样就成功退出服务器了。当然，由于MySQL的知名度日益增加，许多第三方软件公司推出了MySQL在Windows环境中的具有图形界面的支持软件，如EMS公司的EMS MYSQL MANAGER就提供了Windows形式的MySQL数据库操作功能。C API数据类型包括：MYSQL（数据库连接句柄）、MYSQL_RES（查询返回结果集）、MYSQL_ROW（行集）、MYSQL_FIELD（字段信息）、MYSQL_FIELD_OFFSET（字段表的偏移量）、my_ulonglong（自定义的无符号整型数）等；C API提供的函数包括：mysql_close()、mysql_connect()、mysql_query()、mysql_store_result()、mysql_init()等，其中mysql_query()最为重要，能完成绝大部分的数据库操控。3.2 CDatabase类在VC中的应用第一步 建立初始化MySQL对象，并且将其初始化。即定义CDatabase类对象，这样程序就会自动调用构造函数CDatabase()，完成初始化。构造函数实现如下：CDatabase:CDatabase () mysql_init (&mysql);完成初始化只需定义CDatabase类对象，即CDatabase base;第二步 连接服务器，并连接需要的数据库。即调用ConnectDB(Database_Param *p)函数，结构体Database_Param中存放数据库参数，包括主机名、用户名、密码、数据库名等。该函数如返回TRUE表示连接成功，否则表示失败。连接函数实现如下： BOOL CDatabase:ConnectDB(Database_Param *p)if(!mysql_real_connect(&mysql,p-host,p-user,p-password,p-db,p-port,p-unix_socket,p-client_flag) OutErrors(); / 输出错误信息 return false; return true;第三步 对数据库进行加锁。即调用LockTable(char* TableName,char* PRIORITY)，对相应的表TableName完成相应属性PRIORITY的加锁，使程序兼容多线程功能。 加锁函数实现如下： BOOL CDatabase:LockTable(char* TableName,char* PRIORITY) char str50; sprintf(str,LOCK TABLES %s %s,TableName,PRIORITY); if(mysql_query(&mysql,str) return false; return true;第四步 完成数据库操作。即根据需要调用UpdateRecord(Data_Param *para)、SelectRecord(Data_Param *para)、InsertRecord(Data_Param *para)、DelRecord(Data_Param *para)等操作。其中的结构体Data_Param中存放数据库操作参数。上述两个结构体的定义在global.h中。 InsertRecord函数实现如下，其它实现方法相似： BOOL CDatabase:InsertRecord(Data_Param *para) char str80; sprintf(str,insert into %s values(%s),para-tab_name,para-insert_val); if(mysql_query(&mysql,str) return false; return true;第五步 解锁数据库。即调用UnLockTable()，完成对上述被加锁的表的解锁。 解锁函数实现如下： BOOL CDatabase:UnLockTable() if(mysql_query(&mysql,UNLOCK TABLES) return false; return true;第六步 关闭数据库连接。即调用析构函数CDatabase()，关闭数据库，并自动释放初始化时定义的CDatabase类对象。 析构函数如下： CDatabase:CDatabase() if(query) mysql_free_result(query); mysql_close(&mysql);注意：在编译程序时，必须加入MySQL的库文件libmySQL.lib。哦，还有大家把winsock.h放在mysql.h前面，否则会有sock错误， ( zqh7850430 发表于 2006-4-4 19:27:00)有两点注意的，：，记得加入mysql.h和winsock.h2,记得在设置里加入libmysql.libwsock32.lib然后还记得设置include和lib文件夹，就可以了2.2.3 客户/服务器模式 在TCP/IP网络应用中，通信的两个进程间相互作用的主要模式是客户/服务器模式（Client/Server model），即客户向服务器发出服务请求，服务器接收到请求后，提供相应的服务。客户/服务器模式的建立基于以下两点：首先，建立网络的起因是网络中软硬件资源、运算能力和信息不均等，需要共享，从而造就拥有众多资源的主机提供服务，资源较少的客户请求服务这一非对等作用。其次，网间进程通信完全是异步的，相互通信的进程间既不存在父子关系，又不共享内存缓冲区，因此需要一种机制为希望通信的进程间建立联系，为二者的数据交换提供同步，这就是基于客户/服务器模式的TCP/IP。客户/服务器模式在操作过程中采取的是主动请求方式：首先服务器方要先启动，并根据请求提供相应服务：1. 打开一通信通道并告知本地主机，它愿意在某一公认地址上（周知口，如FTP为21）接收客户请求；2. 等待客户请求到达该端口；3. 接收到重复服务请求，处理该请求并发送应答信号。接收到并发服务请求，要激活一新进程来处理这个客户请求（如UNIX系统中用fork、exec）。新进程处理此客户请求，并不需要对其它请求作出应答。服务完成后，关闭此新进程与客户的通信链路，并终止。4. 返回第二步，等待另一客户请求。5. 关闭服务器客户方：1. 打开一通信通道，并连接到服务器所在主机的特定端口；2. 向服务器发服务请求报文，等待并接收应答；继续提出请求.3. 请求结束后关闭通信通道并终止。从上面所描述过程可知：1. 客户与服务器进程的作用是非对称的，因此编码不同。2. 服务进程一般是先于客户请求而启动的。只要系统运行，该服务进程一直存在，直到正常或强迫终止。2.2.4 套接字类型 TCP/IP的socket提供下列三种类型套接字。流式套接字（SOCK_STREAM）提供了一个面向连接、可靠的数据传输服务，数据无差错、无重复地发送，且按发送顺序接收。内设流量控制，避免数据流超限；数据被看作是字节流，无长度限制。文件传送协议（FTP）即使用流式套接字。数据报式套接字（SOCK_DGRAM）提供了一个无连接服务。数据包以独立包形式被发送，不提供无错保证，数据可能丢失或重复，并且接收顺序混乱。网络文件系统（NFS）使用数据报式套接字。原始式套接字（SOCK_RAW）该接口允许对较低层协议，如IP、ICMP直接访问。常用于检验新的协议实现或访问现有服务中配置的新设备。MFC提供了两个类来支持使用WindowsSocketsAPI编程。其中之一是CSocket，提供一个高层次的抽象来简化你的网络通信编程。Stream Socket： Stream Socket为不记录边界的数据流提供字节流。流保证被投递并且正确的序列和不重复的投递。演示了程序怎样调用WSAStartup来支持2.2版本的DLL： WORD wVersionRequested; WSAData wsaData; int err; wVersionRequested = MAKEWORD(2,2); err=WSAStartup(wVersionRequested,&wsaData); if(err!=0) return; if(LOBYTE(wsaData.wVersion)!=2| HIBYTE(wsaData.wVersion)!=2) WSACleanup(); return; /开始使用windows sockets。 一旦程序或者DLL成功调用了WSAStartup，就可以调用其他的windows sockets函数了。在使用完WS2_32.DLL后，程序或者DLL应该调用WSACleanup来释放资源。在调用WSACleanup时分配的socket会复位并自动清除，就好像调用了closesocket一样.bind函数应用在调用connect或者listen函数之前的未连接的socket上。它用于绑定面向连接（流）或者面向无连接（数据报）socket上。当socket被socket（）函数创建后，它就存在于一个名字空间（地址家族）中，只是它还是未命名的对象。使用bind函数来建立socket的本地关联，它赋值给socket一个本地名称。调c接口主要使用第2这种方式，其实我们是调mysql提供的c接口，所以需要包含它的一些头文件lib等准备：随意新建一个MFC工程下面配置vc内容：工具-选项-目录 增加Include Files：C:MYSQL-5.1.40-WIN32INCLUDE 增加lib files：C:MYSQL-5.1.40-WIN32LIBDEBUG工程-设置-连接 增加 对象/库模块 ：libmysql.lib 如果有其他的，已空格间隔就可以/connection if (mysql_real_connect(sock, ho