Форум программистов [Powered by Invision Power Board]

Код

// **** Read Image from Filesystem and add it to the Database. 
        public void AddEmployee(
            string UserID,
            string UserName,
            string UserEmail,
            string UserDescription,
            //DateTime hireDate,
            //int preportsTo,
            string photoFilePath)
        {

            // Read Image into Byte Array from Filesystem
            byte[] photo = GetPhoto(photoFilePath);

            // Construct INSERT Command
            OleDbCommand addEmp = new OleDbCommand(
                "INSERT INTO Users ("+
                "UserID,UserName,UserEmail,UserDescription,UserPhoto) " +
                "VALUES(@UserID,@UserName,@UserEmail,@UserDescription,@UserPhoto)", conn); //@ReportsTo ReportsTo

            addEmp.Parameters.Add("@UserID", OleDbType.VarChar, 20).Value = UserID;
            addEmp.Parameters.Add("@UserName", OleDbType.VarChar, 20).Value = UserName;
            addEmp.Parameters.Add("@UserEmail", OleDbType.VarChar, 20).Value = UserEmail;
            addEmp.Parameters.Add("@UserDescription", OleDbType.VarChar, 20).Value = UserDescription;
            //addEmp.Parameters.Add("@ReportsTo", SqlDbType.Int).Value          = preportsTo;
            addEmp.Parameters.Add("@UserPhoto",     OleDbType.Binary, photo.Length).Value = photo;

            // Open the Connection and INSERT the BLOB into the Database
            conn.Open();
            addEmp.ExecuteNonQuery();
            conn.Close();
        }

        // **** Read Image into Byte Array from Filesystem
        public static byte[] GetPhoto(string filePath)
        {
            FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Read);
            BinaryReader br = new BinaryReader(fs);

            byte[] photo = br.ReadBytes((int)fs.Length);

            br.Close();
            fs.Close();

            return photo;
        }

        // **** Read BLOB from the Database and save it on the Filesystem
        public void GetEmployee(string UserID,string UserName)
        {
            OleDbCommand getEmp = new OleDbCommand(
                "SELECT  UserPhoto " +
                "FROM Users "+
                "WHERE UserID = @UserID " +
                "AND UserName = @UserName", conn);

            getEmp.Parameters.Add("@UserID", OleDbType.VarChar, 20).Value = UserID;
            getEmp.Parameters.Add("@UserName", OleDbType.VarChar, 20).Value = UserName;

            FileStream fs;                          // Writes the BLOB to a file (*.bmp).
            BinaryWriter bw;                        // Streams the BLOB to the FileStream object.
            int bufferSize = 100;                   // Size of the BLOB buffer.
            byte[] outbyte = new byte[bufferSize];  // The BLOB byte[] buffer to be filled by GetBytes.
            long retval;                            // The bytes returned from GetBytes.
            long startIndex = 0;                    // The starting position in the BLOB output.
            string emp_id = "";                     // The employee id to use in the file name.

            // Open the connection and read data into the DataReader.
            conn.Open();
            OleDbDataReader myReader = getEmp.ExecuteReader(CommandBehavior.SequentialAccess);

            while (myReader.Read())
            {
                // Get the employee id, which must occur before getting the employee.
                emp_id = myReader.GetInt32(0).ToString();

                // Create a file to hold the output.
                fs = new FileStream("Users" + UserID + ".bmp", 
                                    FileMode.OpenOrCreate, FileAccess.Write);
                bw = new BinaryWriter(fs);

                // Reset the starting byte for the new BLOB.
                startIndex = 0;

                // Read the bytes into outbyte[] and retain the number of bytes returned.
                retval = myReader.GetBytes(1, startIndex, outbyte, 0, bufferSize);

                // Continue reading and writing while there are bytes beyond the size of the buffer.
                while (retval == bufferSize)
                {
                    bw.Write(outbyte);
                    bw.Flush();

                    // Reposition the start index to the end of the last buffer and fill the buffer.
                    startIndex += bufferSize;
                    retval = myReader.GetBytes(1, startIndex, outbyte, 0, bufferSize);
                }

                // Write the remaining buffer.
                bw.Write(outbyte, 0, (int)retval);
                bw.Flush();

                // Close the output file.
                bw.Close();
                fs.Close();
            }

            // Close the reader and the connection.
            myReader.Close();
            conn.Close();
        }

        private void btnAddEmp_Click(object sender, System.EventArgs e)
        {
            //DateTime hireDate = DateTime.Now;
            AddEmployee(textBox1.Text, textBox2.Text, textBox3.Text, textBox4.Text, _fname);//Convert.ToInt16(textBox4.Text)
            statusBar.Text = "Employee added to the Database";
            pbxPhoto.Hide();
            textBox1.Clear();
            textBox2.Clear();
            textBox3.Clear();
            textBox4.Clear();
            //textBox5.Clear();
            
        }

        private void btnGetEmp_Click(object sender, System.EventArgs e)
        {
            pbxPhoto.Show();
            GetEmployee(textBox1.Text,"");
            statusBar.Text = "Employee saved to Filesystem";
        }

        private void btnLoadPhoto_Click(object sender, System.EventArgs e)
        {
            OpenFileDialog dlg = new OpenFileDialog();

            dlg.Title = "Open Photo";
            dlg.Filter = "Windows Bitmap Files (*.bmp)|*.bmp"
                + "|All files (*.*)|*.*";

            if (dlg.ShowDialog() == DialogResult.OK)
            {
                try
                {
                    pbxPhoto.Image = new Bitmap(dlg.OpenFile());
                    _fname = dlg.FileName;
                }
                catch (Exception ex)
                {
                    MessageBox.Show("Unable to load file: " + ex.Message);
                }
            }

            dlg.Dispose();
        }