shirome shirome - 6 months ago 52
SQL Question

How to store a file in sql server from winforms c++

MY QUESTION: how do I store a file in a sql server using c++ from a windows form application?

MY PROBLEM: I am reading in binary data from a file then opening a connection to a SQL Server 2014. When I send my sql command to the database with the binary data, I get an error message "Failed to convert parameter value from a Byte to a Byte[].". I see many people using this method in C# applications. How do I adapt this for c++?

MY CODE:

void AddFileToDatabase() {
unsigned char* binaryData; // holds the files binary data
int sizeOfBinaryData = 0; // the size of binaryData in bytes

// Open the test file in binary mode and read the contents into 'binaryData'
std::ifstream inFile("a.txt", std::ios::in | std::ios::binary); // open the test file 'a.txt'
if(inFile.is_open()) {
inFile.seekg(0,std::ios::end); // move to the end of the file
sizeOfBinaryData = (int)inFile.tellg(); // get the file size
inFile.seekg(0,std::ios::beg); // move to the start of the file

binaryData = new unsigned char[sizeOfBinaryData]; // create space for the binary data
inFile.read((char*)binaryData,sizeOfBinaryData); // read in the binary data
inFile.close(); // close the file
}

// Connect to the database
System::Data::SqlClient::SqlConnection^ Connection = gcnew System::Data::SqlClient::SqlConnection("server=MYserver,MYport;Integrated security=SSPI;Database=MYdatabase;"); // create a connection to the database
Connection->Open(); // open the connection to the database

// Setup the sql command
System::Data::SqlClient::SqlCommand^ Command = gcnew System::Data::SqlClient::SqlCommand("INSERT INTO MYtable VALUES(@binaryValue);", Connection); // create the sql command (the column type in MYtable is 'varbinary(MAX)')
System::Byte^ data = gcnew System::Byte(reinterpret_cast<unsigned char>(binaryData)); // store the binary data in a System::Byte type so the sql Command will accept it as a parameter
Command->Parameters->Add("@binaryValue", System::Data::SqlDbType::VarBinary, sizeOfBinaryData)->Value = data; // add the binary data to the sql command

// Attempt to insert the binary data into the database
try {
Command->ExecuteNonQuery(); // insert binay data into database
System::Windows::Forms::MessageBox::Show("IT WORKED!!!","Success", System::Windows::Forms::MessageBoxButtons::OK,System::Windows::Forms::MessageBoxIcon::Information); // tell us if we are big winners
}
catch(System::Exception^ ex) {
System::Windows::Forms::MessageBox::Show(ex->Message,"Error", System::Windows::Forms::MessageBoxButtons::OK,System::Windows::Forms::MessageBoxIcon::Error); // tell us why we failed
}

delete[] binaryData; // clean up
}

Answer

MY SOLUTION: The solution here is to change 'data' from type 'System::Byte^' to 'array^'

SOLUTION CODE:

void AddFileToDatabase()  {
    // Open the test file in binary mode and read the contents into 'binaryData'
    unsigned char* binaryData;  // holds the files binary data
    int sizeOfBinaryData = 0;  // the size of stream in bytes

    FILE* in;  fopen_s(&in,"a.txt","rb");  // open the file in binary mode
    fseek(in,0,SEEK_END);  // move to the end of the file
    sizeOfBinaryData = ftell(in);  // get the file size
    fseek(in,0,SEEK_SET);  // move to the start of the file
    binaryData = new unsigned char[sizeOfBinaryData];  // create space for the binary data
    fread(binaryData,sizeof(unsigned char),sizeOfBinaryData,in);  // read in the binary data
    fclose(in);  // close the file

    // Connect to the database
    System::Data::SqlClient::SqlConnection^ Connection = gcnew System::Data::SqlClient::SqlConnection("server=MYserver,MYport;Integrated security=SSPI;Database=MYdatabase;");  // create a connection to the database
    Connection->Open();  // open the connection to the database

    // Setup the sql command
    System::Data::SqlClient::SqlCommand^ Command = gcnew System::Data::SqlClient::SqlCommand("INSERT INTO Files(BYTEcolumn,SIZEcolumn) VALUES(@binaryValue,'" + sizeOfBinaryData + "');", Connection);  // create the sql command
    array<System::Byte>^ data = gcnew array<System::Byte>(sizeOfBinaryData);  // create a Byte array
    for(int i = 0; i < sizeOfBinaryData; i++)  {
        data[i] = binaryData[i];  // store the binary data in a System::Byte array type so the sql Command will accept it as a parameter
    }
    Command->Parameters->Add("@binaryValue", System::Data::SqlDbType::VarBinary, sizeOfBinaryData)->SqlValue = data;  // add the binary data to the sql command

    // Attempt to insert the binary data into the database
    try  {
        Command->ExecuteNonQuery();  // insert binay data into database
        System::Windows::Forms::MessageBox::Show("IT WORKED!!!","Success", System::Windows::Forms::MessageBoxButtons::OK,System::Windows::Forms::MessageBoxIcon::Information);  // tell us if we are big winners
    }
    catch(System::Exception^ ex)  {
        System::Windows::Forms::MessageBox::Show(ex->Message,"Error", System::Windows::Forms::MessageBoxButtons::OK,System::Windows::Forms::MessageBoxIcon::Error);  // tell us why we failed
    }

    delete[] binaryData;  // clean up
}

and here is how to retrieve the file from the database.

void GetFileFromDatabase()  {
    // Connect to the database
    System::Data::SqlClient::SqlConnection^ Connection = gcnew System::Data::SqlClient::SqlConnection("server=MYserver,MYport;Integrated security=SSPI;Database=MYdatabase;");  // create a connection to the database
    Connection->Open();  // open the connection to the database

    // Setup the sql command
    System::Data::SqlClient::SqlCommand^ Command = gcnew System::Data::SqlClient::SqlCommand("SELECT SIZEcolumn,BYTEcolumn FROM Files WHERE IDcolumn = MYid;", Connection);  // create the sql command

    // try to get the file from the database
    System::Data::SqlClient::SqlDataReader^ Reader;  // setup a sql data reader object to capture the data from the database
    try  {
        Reader = Command->ExecuteReader();  // send the request to the database and put the result in the sql data reader
        if(Reader)  {  // if the sql data reader has been set
            if(!Reader->IsClosed)  {  // if the sql data reader is not closed
                if(Reader->HasRows)  {  // if there is data in the sql data reader
                    int sizeOfBinaryData = 0;  // storage for the size of the file
                    while(Reader->Read())  {  // loop through the data 
                        for(int i = 0;i < Reader->FieldCount; i++)  {  // cycle through the Size and Bytes fields of the data
                            if(!Reader->IsDBNull(i))  {  // if the current data field is not emplty

                                if(Reader->GetFieldType(i)->ToString() == "System.Int32")  {  // if the current field is the size of the next file
                                    sizeOfBinaryData = Reader->GetInt32(i);  // get the size of the next file
                                }else if(Reader->GetFieldType(i)->ToString() == "System.Byte[]")  {  // if the current field is the byte data
                                    if(sizeOfBinaryData)  {  // if the size of the byte data is more than 0

                                        array<System::Byte>^ data = gcnew array<System::Byte>(sizeOfBinaryData);  // create an Byte array to store the data
                                        Reader->GetBytes(i,0,data,0,sizeOfBinaryData);  // read the byte data into the Byte array

                                        unsigned char* binaryData = new unsigned char[sizeOfBinaryData];  // create an unsigned char array so fwrite() will accept the array type
                                        for(int i = 0; i < sizeOfBinaryData; i++)  {
                                            binaryData[i] = data[i];  // copy the byte data to the unsigned char array
                                        }

                                        // create a new file from the byte data
                                        FILE* out;  fopen_s(&out,"b.txt","wb");  // open the file where you want to store the data
                                        fwrite(binaryData,sizeof(unsigned char),sizeOfBinaryData,out);  // write the data to the new file
                                        fclose(out);  // close the file
                                        delete[] binaryData;  // clean up
                                    }
                                }
                            }
                        }
                    }
                    System::Windows::Forms::MessageBox::Show("You got a new file. Good for you!","Success", System::Windows::Forms::MessageBoxButtons::OK,System::Windows::Forms::MessageBoxIcon::Error);  // SUCCESS message
                }
            }
            Reader->Close();  // close the sql data reader
        }
    }catch(System::Exception^ ex)  {
        System::Windows::Forms::MessageBox::Show(ex->Message,"Error", System::Windows::Forms::MessageBoxButtons::OK,System::Windows::Forms::MessageBoxIcon::Error);  // give us error data
    }
}

Thanks everyone for your interest.