#include “stdafx.h”<\/p>\n
using namespace System;
\nusing namespace System::Collections;
\nusing namespace System::Collections::Specialized;
\nusing namespace System::Net;
\nusing namespace System::Net::Sockets;
\nusing namespace System::Threading;
\nusing namespace System:ata;
\nusing namespace System:ata::OleDb;
\nusing namespace System::Text;<\/p>\n
namespace Util
\n{
\npublic ref class SqlServerInfo
\n{
\nprivate :
\nString^ m_ServerName;
\nString^ m_InstanceName;
\nbool\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0m_IsClustered;
\nString^ m_Version;
\nint\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0m_tcpPort;
\nString^ m_Np;
\nString^ m_Rpc;
\nIPAddress^ m_IP;
\nStringCollection m_Catalogs;
\nString^ m_UserId;
\nString^ m_Password;
\nbool\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0m_IntegratedSecurity;
\nint\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0m_TimeOut;
\npublic :
\nString^ srv_name(){ return m_ServerName; }<\/p>\n
SqlServerInfo(){}
\nbool Parser( IPAddress^ ip, array<Byte>^ bytes )
\n{
\ntry
\n{
\nint num = BitConverter::ToInt16( bytes, 1 );
\nASCIIEncoding^ ascii = gcnew ASCIIEncoding();
\nString^ info = ascii->GetString( bytes, 3, num );
\nreturn Parser( ip, info );
\n}catch(…){}
\nreturn false;
\n}
\nbool Parser( IPAddress^ ip, String^ info )
\n{
\nm_IP = ip;
\narray<String^>^ nvs = infSplit(‘;’, 1);<\/p>\n
for (int i = 0; i < nvs->Length; i += 2)
\n{
\nString ^item1 = nvs[i+1];
\nString ^item = nvs[i]->ToLower();
\nif( item == “servername” )
\n{
\nthis->m_ServerName = item1;
\n}else if( item == “instancename” )
\n{
\nthis->m_InstanceName = item1;
\n}else if( item == “isclustered” )
\n{
\nthis->m_IsClustered = (item1->ToLower() == “yes”);
\n}else if( item == “version” )
\n{
\nthis->m_Version = item1;
\n}else if( item == “tcp” )
\n{
\nthis->m_tcpPort = int:arse(item1);
\n}else if( item == “np” )
\n{
\nthis->m_Np = item1;
\n}else if( item == “rpc” )
\n{
\nthis->m_Rpc = item1;
\n}
\n}
\nreturn ( nvs->Length > 0 );
\n}<\/p>\n
OleDbConnection^ GetConnection()
\n{
\nString^ myConnString = m_IntegratedSecurity ?
\nString::Format(“Provider=SQLOLEDB;Data Source={0};Integrated Security=SSPI;Connect Timeout={1}”, this, m_TimeOut)
\n: String::Format(“Provider=SQLOLEDB;Data Source={0};User Id={1};Password={2};Connect Timeout={3}”,
\nthis, m_UserId, m_Password, m_TimeOut);<\/p>\n
return gcnew OleDbConnection( myConnString );
\n}
\nbool TestConnection()
\n{
\nOleDbConnection^ conn = this->GetConnection();
\nbool success = false;
\ntry
\n{
\nconn->Open();
\nconn->Close();
\nsuccess = true;
\n}
\ncatch(…){}
\nreturn success;
\n}
\nvirtual String^ ToString() override
\n{
\nif( String::IsNullOrEmpty(m_InstanceName) || m_InstanceName == “MSSQLSERVER”)
\nreturn m_ServerName;
\nelse
\nreturn m_ServerName + “\\\\” + m_InstanceName;
\n}
\nStringCollection^ GetCatalogs()
\n{
\nStringCollection^ catalogs = gcnew StringCollection();
\ntry
\n{
\nOleDbConnection^ myConnection = this->GetConnection();
\nmyConnection->Open();
\narray<Object^>^ restrictions;
\nDataTable^ schemaTable = myConnection->GetOleDbSchemaTable( OleDbSchemaGuid::Catalogs, restrictions );
\nmyConnection->Close();<\/p>\n
for( int i = 0; i < schemaTable->Rows->Count; i++ )
\n{
\nDataRow^ dr = schemaTable->Rows[i];
\nString^ dir = \u00a0dr[i]->ToString();
\ncatalogs->Add( dir );
\n}
\n}
\ncatch(Exception^ ex)
\n{
\nSystem::Windows::Forms::MessageBox::Show(ex->Message);
\n}
\nreturn catalogs;
\n}
\nstatic array<SqlServerInfo^>^ Seek()
\n{
\nSocket^ socket = gcnew Socket(AddressFamily::InterNetwork, SocketType:gram, ProtocolType::Udp);<\/p>\n
\/\/ \u00a0For .Net v 1.1
\n\/\/\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0socket->SetSocketOption(SocketOptionLevel::Socket, SocketOptionName::Broadcast, 1);
\n\/\/\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0socket->SetSocketOption(SocketOptionLevel::Socket, SocketOptionName::ReceiveTimeout, 3000);<\/p>\n
\/\/ \u00a0For .Net v 2.0 it’s a bit simpler
\nsocket->EnableBroadcast = true;\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ for .Net v2.0
\nsocket->ReceiveTimeout = 3000;\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ for .Net v2.0<\/p>\n
ArrayList^ servers = gcnew ArrayList();
\ntry
\n{
\narray<Byte>^ msg= {0x02};
\nIPEndPoint^ ep = gcnew IPEndPoint(IPAddress::Broadcast, 1434);
\nsocket->SendTo( msg, SocketFlags::None, ep );<\/p>\n
int cnt = 0;
\narray<Byte>^ bytBuffer = gcnew array<Byte>(1024);
\nArrayList^ lst = gcnew ArrayList();
\ndo
\n{
\ncnt = socket->Receive(bytBuffer);
\nIPAddress^ ip;
\nSqlServerInfo^ srv = gcnew SqlServerInfo;
\nif( srv->Parser( ip, bytBuffer ) )
\n{
\nString^ srv_name = srv->m_ServerName;
\nString^ inst_name = srv->m_InstanceName;
\nif( !String::IsNullOrEmpty( inst_name ) )
\n{
\nsrv_name = srv_name + “\\\\” + inst_name;
\n}
\nif( lst->IndexOf( srv_name ) < 0 )
\n{
\nservers->Add( srv );
\nlst->Add( srv_name );
\n}
\n}
\nsocket->SetSocketOption(SocketOptionLevel::Socket, SocketOptionName::ReceiveTimeout, 300);
\n}while( cnt != 0 );
\n}
\ncatch (SocketException^ socex)
\n{
\nconst int WSAETIMEDOUT = 10060;\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ Connection timed out.
\nconst int WSAEHOSTUNREACH = 10065;\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ No route to host.<\/p>\n
\/\/ Re-throw if it’s not a timeout.
\nif (socex->ErrorCode == WSAETIMEDOUT || socex->ErrorCode == WSAEHOSTUNREACH)
\n{
\n\/\/ DO nothing……
\n}
\nelse
\n{
\n\/\/Console->WriteLine(“{0} {1}”, socex->ErrorCode, socex->Message);
\nthrow;
\n}
\n}
\nfinally
\n{
\nsocket->Close();
\n}
\narray<SqlServerInfo^>^ aServers = gcnew array<SqlServerInfo^>( servers->Count );
\nservers->CopyTo(aServers);
\nreturn aServers;
\n}
\n};
\n}<\/p>\n
void DBConnect::loadServerList()
\n{
\ncboxServer->Items->Clear();
\narray<SqlServerInfo^>^ lst = Util::SqlServerInfo::Seek();
\nfor(int i = 0; i < lst->Length; i++)
\n{
\nSqlServerInfo^ name_srv = lst[i];
\nString^ name = name_srv->srv_name();
\nif( !String::IsNullOrEmpty( name ) )
\n{
\ncboxServer->Items->Add( name );
\n}
\n}
\n}<\/p>\n","protected":false},"excerpt":{"rendered":"
#include “stdafx.h” using namespace System; using namespace System::Collections; using namespace System::Collections::Specialized; using namespace System::Net; using namespace System::Net::Sockets; using namespace System::Threading; using namespace System:ata; using namespace System:ata::OleDb; using namespace System::Text; namespace Util { public ref class SqlServerInfo { private : String^ m_ServerName; String^ m_InstanceName; bool\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0m_IsClustered; String^ m_Version; int\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0m_tcpPort; String^ m_Np; String^ m_Rpc; IPAddress^ m_IP; StringCollection m_Catalogs;… <\/p>\n