Database

class MyClass<br />
{<br />
	string sql = "select * from table1";<br />
	string conn_s = "...";<br />
	<br />
		private bool threadFail = false;<br />
		private bool ThreadFail <br />
		{<br />
			get <br />
			{<br />
				lock ( this ) <br />
				{<br />
					return threadFail;<br />
				}<br />
			}<br />
			set<br />
			{<br />
				lock ( this ) <br />
				{<br />
					threadFail = value;<br />
				}<br />
			}<br />
		}<br />
<br />
		private void DoQuery()<br />
		{<br />
			DataSet ds = new DataSet();<br />
			OleDbDataAdapter da = new OleDbDataAdapter(sql, conn_s);<br />
<br />
			while ( !ThreadFail ) <br />
			{<br />
				try <br />
				{<br />
					da.Fill(ds);<br />
					Thread.Sleep(100);<br />
				} <br />
				catch ( Exception e ) <br />
				{<br />
					ThreadFail = true;<br />
				}<br />
			}<br />
		}<br />
<br />
		public void Test()<br />
		{<br />
			int i = 0;<br />
			while ( !ThreadFail ) <br />
			{<br />
				i++;<br />
				Thread t = new Thread(new ThreadStart(DoQuery));<br />
				t.Start();<br />
				Thread.Sleep(100);<br />
			}<br />
			ShowMessage( "Total threads = " + i );<br />
		}<br />
}

<br />
    Public Function StoreFile(ByVal FileData As Byte(), ByVal ServerName As String, ByVal SqlPassword As String, ByVal SqlUser As String)<br />
        'Make the Connection to the SQL server<br />
        Dim ConnectionString As String = ""<br />
        ConnectionString = ConnectionString & "data source=" & ServerName & ";"<br />
        ConnectionString = ConnectionString & "password=" & SqlPassword & ";"<br />
        ConnectionString = ConnectionString & "persist security info=False;"<br />
        ConnectionString = ConnectionString & "user id=" & SqlUser & ";"<br />
        'ConnectionString = ConnectionString & "packet(Size = 4096)"<br />
<br />
        Try<br />
            'Declare the Connection Object.<br />
            Dim Conn As SqlConnection = New SqlConnection(ConnectionString)<br />
            'Open the Connection.<br />
            Conn.Open()<br />
<br />
<br />
            'Declare a DataAdapter.<br />
            Dim DA As SqlDataAdapter = New SqlDataAdapter()<br />
<br />
            'Set the Select,Delete,Insert, and Update Command for this DataAdapter<br />
            DA.SelectCommand = New SqlCommand("SELECT DOC_Type, DOC_Data, DOC_ID FROM EDIAPPS.dbo.Documents_All", Conn)<br />
            DA.InsertCommand = New SqlCommand("INSERT INTO EDIAPPS.dbo.Documents_All(DOC_Type, DOC_Data) VALUES (@DOC_Type, @DOC_Data); SELECT DOC_Type, DOC_Data, DOC_ID FROM EDIAPPS.dbo.Documents_All WHERE (DOC_ID = @@IDENTITY)", Conn)<br />
            DA.UpdateCommand = New SqlCommand("UPDATE EDIAPPS.dbo.Documents_All SET DOC_Type = @DOC_Type, DOC_Data = @DOC_Data WHERE (DOC_ID = @Original_DOC_ID) AND (DOC_Type = @Original_DOC_Type); SELECT DOC_Type, DOC_Data, DOC_ID FROM EDIAPPS.dbo.Documents_All WHERE (DOC_ID = @DOC_ID)", Conn)<br />
            DA.DeleteCommand = New SqlCommand("DELETE FROM EDIAPPS.dbo.Documents_All WHERE (DOC_ID = @Original_DOC_ID) AND (DOC_Type = @Original_DOC_Type)", Conn)<br />
<br />
            'Delclare a dataSet Object.<br />
            Dim DS As New DataSet()<br />
<br />
            'Fill the Dataset with the Table data from the Database.<br />
            DA.Fill(DS)<br />
<br />
            'Delclare a New DataRow Object.<br />
            Dim DR As DataRow = DS.Tables(0).NewRow<br />
<br />
            'Populate the new row with our information.<br />
            DR("DOC_Type") = 1<br />
            DR("DOC_Data") = FileData<br />
<br />
            'Add New Row to out DataSet.<br />
            DS.Tables(0).Rows.Add(dr)<br />
            DS.AcceptChanges()<br />
<br />
            'Update the Database with our changes.<br />
            DA.Update(DS)<br />
            Conn.Close()<br />
        Catch Ex As Exception<br />
            MessageBox.Show(Ex.Message, "Application Error", MessageBoxButtons.OK)<br />
            Return False<br />
        Catch DBE As SqlClient.SqlException<br />
            MessageBox.Show(DBE.Message, "SQL Error", MessageBoxButtons.OK)<br />
            Return False<br />
        Finally<br />
        End Try<br />
<br />
    End Function<br />