1

Amigos, por ordem da empresa, preciso pegar todos os arquivos que um sistema armazena em um diretório do Windows e armazenar no Banco de Dados.

No banco de dados existe uma coluna que armazena o diretório onde os arquivos estão, eu pensei em percorrer cada linha da coluna que armazena o path dos arquivos usando o DataReader, converter o arquivo para binário e armazenar no banco.

O que tenho até agora é isso, mas estou travado:

static void FileStreamMethod()
    {
        /*Conecta ao SQL*/
        SqlConnection cnnSQL = new SqlConnection(@"Data Source=xxxx; " +
                                                 "Initial Catalog=SCF2_HOMOLOG;" +
                                                 "User ID=xxxxx;" +
                                                 "Password=xxxxx");

        SqlCommand sqlCommand = new SqlCommand("SELECT id_DocumentoProcessoCompra, Path_Documento " +
                                               "FROM SCF_DocumentoProcessoCompra", cnnSQL);

        try { cnnSQL.Open(); }
        catch (SqlException ex) { Console.WriteLine(ex.Message); }

        SqlDataReader sqlDataReader = sqlCommand.ExecuteReader();


        if (sqlDataReader.HasRows)
        {
            while (sqlDataReader.Read())
            {
                try
                {
                    string path = @"C:\Users\Lucas Garcia\Desktop\AnexoProcesso\" + sqlDataReader.GetString(1);
                    /* Objeto origem do arquivo */
                    FileStream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read);

                    /*Le o binario do arquivo*/
                    BinaryReader binaryReader = new BinaryReader(fileStream);
                    byte[] files = binaryReader.ReadBytes(Convert.ToInt32(fileStream.Length));

                    SqlCommand sqlUpdateCommand = new SqlCommand("UPDATE SCF_DocumentoProcessoCompra " +
                                                                 "SET Documento = " + files +
                                                                 "WHERE id_ModeloDocumento = " + sqlDataReader.GetInt32(0), cnnSQL);

                    sqlUpdateCommand.ExecuteNonQuery();

                    binaryReader.Close();
                    fileStream.Close();

                    Console.WriteLine("ID {1}\nDocumento {0} armazenado no DB", sqlDataReader.GetString(1), sqlDataReader.GetInt32(0));
                }
                catch (SqlException ex)
                {
                    Console.WriteLine(ex.Message);
                }

            }
        }
        else
        {
            Console.WriteLine("No rows found.");
        }

        sqlDataReader.Close();
    }
4
  • qual é exatamente a sua dúvida? 9/01/2018 às 20:19
  • Qual é o tipo da coluna que vai armazenar o arquivo no banco de dados? 10/01/2018 às 12:21
  • Estou tendo o seguinte erro: 'Já existe um DataReader aberto associado a este Command que deve ser fechado primeiro' no sqlUpdateCommand.ExecuteNonQuery(); que é responsável pelo update do campo na tabela.
    – Lucas
    10/01/2018 às 13:12
  • Volte a versão do código que você havia postado, se você ficar editando conforme as respostas pode acabar confundindo o entendimento do problema original e dificultando que outros possam ajudar você também. 10/01/2018 às 14:21

2 Respostas 2

0

Segue um exemplo de abordagem para o seu problema, se o sql tem acesso ao repositório onde estão os arquivos, você pode fazer por ele mesmo.

static void FileStreamMethod()
    {
        /*Conecta ao SQL*/
        SqlConnection cnnSQL = new SqlConnection("Data Source=x.x.x.x;" +
                                                 "Initial Catalog=db_base_clientes;" +
                                                 "User ID=base_clientes;" +
                                                 "Password=xxxxx");
        cnnSQL.Open();

        SqlDataReader sqlDataReader = sqlCommand.ExecuteReader();

        if (sqlDataReader.HasRows)
        {
            while (sqlDataReader.Read())
            {
                /* Objeto para origem do arquivo */
                string path = @"C:\"; // EXISTE UMA COLUNA NO SQL COM OS PATHS, FAZER foreach PARA CADA PATH
                using(fileStream = new FileStream(path, FileMode.Open, FileAccess.Read)){

                    byte[] documento;
                    /*Le o binario*/
                    using( binaryReader = new BinaryReader(fileStream))
                    {
                        documento = binaryReader.ReadBytes(Convert.ToInt32(fileStream.Length));
                    }

                    try
                    {
                        //Substitua [ID] pela sua coluna de índice
                        SqlCommand sqlUpdateCommand = new SqlCommand("UPDATE SCF_DocumentoProcessoCompra" +
                                                                        "SET Documento = @documento" +
                                                                    "WHERE [ID] = @ID ", cnnSQL);

                        //Você precisa saber o tipo da coluna para escolher o SqlDbType adequado.
                        //Deixei como Image só para exemplo
                        sqlUpdateCommand.Add("@documento", SqlDbType.Image, documento.Length).Value = file;
                        sqlUpdateCommand.Add("@id", SqlDbType.Int).Value = 0 // <- Coloque aqui o seu atributo de id da linha que está lendo;

                        sqlUpdateCommand.ExecuteNonQuery();
                        sqlUpdateCommand.Dispose();

                    }
                    catch(Exeption e){
                        sqlDataReader.Close();
                        cnnSQL.Close();                            
                        throw e;
                    }
                }               

            }
        }
        else
        {
            Console.WriteLine("No rows found.");
        }

    sqlDataReader.Close();
    //Não esqueça de fechar a conexão do banco
    cnnSQL.Close();
}
3
  • Estou tendo o seguinte erro: 'Já existe um DataReader aberto associado a este Command que deve ser fechado primeiro' no sqlUpdateCommand.ExecuteNonQuery(); que é responsável pelo update do campo na tabela.
    – Lucas
    10/01/2018 às 13:14
  • Leandro, atualizei o post principal conforme esta meu codigo.
    – Lucas
    10/01/2018 às 13:17
  • tava faltando um .Dispose() 10/01/2018 às 14:11
0

O DataReader não aceita 2 comandos SQL na mesma conexão. Sendo assim fiz uma gambiarra(já que só vou executar isso uma única vez e nunca mais) e abri 2 conexões com o SQL. Resolvi o problema assim:

static void FileStreamMethod()
    {
        /*Conecta ao SQL*/
        SqlConnection cnnSQL = new SqlConnection(@"Data Source=x.x.x.x; " +
                                                 "Initial Catalog=SCF2_HOMOLOG;" +
                                                 "User ID=xxxxxxx;" +
                                                 "Password=xxxxxxx");
        SqlConnection cnnSQL2 = new SqlConnection(@"Data Source=x.x.x.x; " +
                                                 "Initial Catalog=SCF2_HOMOLOG;" +
                                                 "User ID=xxxxxxx;" +
                                                 "Password=xxxxxxx");
        try { cnnSQL.Open(); cnnSQL2.Open(); }
        catch (SqlException ex) { Console.WriteLine(ex.Message); }

        SqlCommand sqlCommand = new SqlCommand("SELECT id_DocumentoProcessoCompra, Path_Documento " +
                                               "FROM SCF_DocumentoProcessoCompra", cnnSQL);


        SqlDataReader sqlDataReader = sqlCommand.ExecuteReader();


        if (sqlDataReader.HasRows)
        {
            while (sqlDataReader.Read())
            {
                try
                {
                    string path = @"C:\Users\Lucas Garcia\Desktop\AnexoProcesso\" + sqlDataReader.GetString(1);
                    /* Objeto origem do arquivo */
                    FileStream fileStream = new FileStream(path, FileMode.Open, FileAccess.Read);

                    /*Le o binario do arquivo*/
                    BinaryReader binaryReader = new BinaryReader(fileStream);
                    byte[] file = binaryReader.ReadBytes(Convert.ToInt32(fileStream.Length));

                    SqlCommand sqlUpdateCommand = new SqlCommand("UPDATE SCF_DocumentoProcessoCompra " +
                                                                 "SET Documento = @documento " +
                                                                 "WHERE id_DocumentoProcessoCompra = @ID", cnnSQL2);

                    sqlUpdateCommand.Parameters.Add("@ID", SqlDbType.Int);
                    sqlUpdateCommand.Parameters["@ID"].Value = sqlDataReader.GetInt32(0);
                    sqlUpdateCommand.Parameters.Add("@documento", SqlDbType.Image);
                    sqlUpdateCommand.Parameters["@documento"].Value = file;

                    sqlUpdateCommand.ExecuteNonQuery();


                    binaryReader.Close();
                    fileStream.Close();

                    Console.WriteLine("ID {1}\nBinario: {2}\nDocumento {0} armazenado no DB", sqlDataReader.GetString(1), sqlDataReader.GetInt32(0), file);
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }

            }
        }
        else
        {
            Console.WriteLine("No rows found.");
        }

        sqlDataReader.Close();
        cnnSQL.Close();
        cnnSQL2.Close();
    }

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .