'数据库连接 Public Sub connectionDB() Try serverUrl = readFromIni(My.Application.Info.DirectoryPath & "config.dll", "Service Information", "IPAddress") serverID = readFromIni(My.Application.Info.DirectoryPath & "config.dll", "Service Information", "Password") serverName = readFromIni(My.Application.Info.DirectoryPath & "config.dll", "Service Information", "userID") serverDataBase = readFromIni(My.Application.Info.DirectoryPath & "config.dll", "Service Information", "DataBaseName") If serverID <> "" Then connectionSqlString = "server =" + serverUrl + ";Database=" + serverDataBase + ";uid =" + serverName + ";pwd=" + serverID + ";max pool size=500" Else connectionSqlString = "server =" & serverUrl & ";integrated security = SSPI ;database = " & serverDataBase & "" End If conSql = New SqlConnection(connectionSqlString) objCommand.Connection = conSql Catch ex As Exception MsgBox(ex.Message) End Try End Sub '数据操作执行 Public Sub getConn(ByVal SqlStr As String, ByVal TableName As String) Try objCommand.CommandText = SqlStr objDataSet.Clear() objDataAdapter.SelectCommand = objCommand objDataAdapter.Fill(objDataSet, TableName) Catch ex As Exception errNo = 1 MsgBox(ex.Message) End Try End Sub '数据更新 Public Sub updateTable(ByVal StrSql As String) objCommand.CommandText = StrSql Try conSql.Open() Trans = conSql.BeginTransaction objCommand.Transaction = Trans objCommand.ExecuteNonQuery() Trans.Commit() Catch ese As Exception MsgBox(ese.Message) Trans.Rollback() '如果更新异常则取消所有更新 Finally conSql.Close() '关闭连接 End Try End Sub