复制代码 代码如下:

'数据库连接

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