forum.clarionlife.net

Код: Выделить всё

Перечислить все SQL сервера в системе.

public static void FindSqlServers (ISQLServerInfoCollection list, int timeout, int port)
       {
          EndPoint point = new IPEndPoint(IPAddress.Broadcast, port);

         Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
         socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.Broadcast, 1);
            socket.Blocking = false;

            byte[] data = {0x02};
         socket.SendTo(data, point);

         byte[] buffer = new byte[512];

          Thread.Sleep(timeout);

          try
         {
              int size = socket.ReceiveFrom(buffer, ref point);
               while (size > 0)
             {
                  SQLServerInfoImpl info = new SQLServerInfoImpl(new string(Encoding.ASCII.GetChars(buffer, 0, size)));

                   if (!list.Contains(info))
                       list.Add(info);

                 size = socket.ReceiveFrom(buffer, ref point);
               }
          }
          catch {}
      }

public SQLServerInfoImpl (string reply)
       {
          string[] data = reply.Split(';', '\0');

            for (int index = 0; index < data.Length; index++)
            {
              if (data[index] == "InstanceName")
                {
                  _instanceName = data[index + 1];
                    index++;
                }

              if (data[index] == "ServerName")
              {
                  _hostName = data[index + 1];
                    index++;
                }

              if (data[index] == "tcp")
             {
                  _port = Convert.ToInt32(data[index + 1]);
                   index++;
                }
          }

          if (_instanceName == "MSSQLSERVER")
               _instanceName = null;
       }


Более правильный вариант
SOCKET hSocket;
BOOL fBroadcast = TRUE;
Byte Data[]={0x02};
Byte Buf[65535];
int i,iBeg,tRes,tLenSA,tLenBufRecv,tFlagStep;
u_long tLenBufIOCTL;
TStringList *MyStr;
AnsiString S,S2,S3;

MyStr=new TStringList;

sockaddr_in saSQLSend,saSQLRecv;

ListBox1->Clear();
MyStr->Clear();


hSocket=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);
if(hSocket==INVALID_SOCKET) return;


tRes=setsockopt(hSocket,SOL_SOCKET,SO_BROADCAST,(CHAR *)&fBroadcast,sizeof(BOOL));
if(tRes==SOCKET_ERROR) {closesocket(hSocket);return;}


saSQLSend.sin_family = AF_INET;
saSQLSend.sin_port= htons ( 1434 );
saSQLSend.sin_addr.s_addr = htonl ( INADDR_BROADCAST );
tRes=sendto(hSocket,Data,1,0,(SOCKADDR *)&saSQLSend,sizeof(SOCKADDR_IN));
if(tRes==SOCKET_ERROR) {closesocket(hSocket);return;}

Sleep(100);


tRes=ioctlsocket(hSocket,FIONREAD,&tLenBufIOCTL);
if(tRes==SOCKET_ERROR) {closesocket(hSocket);return;}


if(tLenBufIOCTL>0)
        {
        tFlagStep=0;
        tLenSA=sizeof(SOCKADDR_IN);
        saSQLRecv=saSQLSend;
        tLenBufRecv=recvfrom(hSocket,Buf,65535,0,(SOCKADDR *) &saSQLRecv,&tLenSA);
        if(tLenBufRecv==SOCKET_ERROR) {closesocket(hSocket);return;}
        iBeg=1;
        S2=(char *)(Buf+3);
        tLenBufRecv-=3;
        for(i=1;i<=tLenBufRecv;i++)
                {
                if(S2[i]==';')
                        {
                        S=S2.SubString(iBeg,i-iBeg);
                        if(tFlagStep==1) S3=S;
                        if(tFlagStep==2)
                                {
                                if(S!="MSSQLSERVER") S3+=("\\"+S);
                                MyStr->Add(S3);
                                ListBox1->Items->Add(S3);
                                S3="";
                                }
                        tFlagStep=0;
                        if(S=="ServerName") tFlagStep=1;
                        if(S=="InstanceName") tFlagStep=2;
                        iBeg=i+1;
                        }
                }
        }
closesocket(hSocket);

Код: Выделить всё

    SQLDriverConnect(|
    LONG        hdbc,|
    UNSIGNED    hwnd,|
    *CSTRING      szConnStrIn,|
    SHORT       cbConnStrIn,|
    *CSTRING      szConnStrOut,|
    SHORT       cbConnStrOutMax,|
    *SHORT      pcbConnStrOut,|
    USHORT      fDriverCompletion),SHORT,RAW,PASCAL,NAME('SQLDRIVERCONNECT'),PROC!,DLL(1)

Код: Выделить всё

SQL_HANDLE_ENV            EQUATE(1)
SQL_HANDLE_DBC            EQUATE(2)
SQL_NULL_HANDLE           EQUATE(0)        
SQL_DRIVER_COMPLETE_REQUIRED    EQUATE(3)
SQL_ERROR               EQUATE(-1)
SQL_SUCCESS             EQUATE(0)
SQL_SUCCESS_WITH_INFO   EQUATE(1)

Код: Выделить всё

    SQLAllocHandle(SHORT HandleType,LONG InputHandle,*LONG OutputHandle),SHORT,RAW,PASCAL,NAME('SQLAllocHandle'),PROC!,DLL(1)

Код: Выделить всё

 ! === Allocate environment handle
 SELF.retcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, SELF.henv)

Код: Выделить всё

 ! === Allocate connection handle
 SELF.retcode = SQLAllocHandle(SQL_HANDLE_DBC, SELF.henv, SELF.hdbc)

Код: Выделить всё

 SELF.retCode = SQLDriverConnect(SELF.hdbc,class_W{PROP:Handle},SELF.ConnectString.S,|
        SELF.ConnectString.Pos,SELF.szOutConn, |
    255, SELF.cbOutConn, CHOOSE(NOT DefaultLogon,0,SQL_DRIVER_COMPLETE_REQUIRED))

Код: Выделить всё

 IF ~(SELF.RetCode = SQL_SUCCESS OR SELF.RetCode = SQL_SUCCESS_WITH_INFO)
   ! ошибка
 END

Код: Выделить всё

    SQLDisconnect(LONG hdbc),SHORT,RAW,PASCAL,NAME('SQLDISCONNECT'),PROC!,DLL(1)

Код: Выделить всё

SELF.retCode = SQLDriverConnect(myfile{prop:hdbc},class_W{PROP:Handle},SELF.ConnectString.S,| 
        SELF.ConnectString.Pos,SELF.szOutConn, | 
    255, SELF.cbOutConn, CHOOSE(NOT DefaultLogon,0,SQL_DRIVER_COMPLETE_REQUIRED))