Como faço para armazenar e recuperar um blob do sqlite

Eu usei sqlite em c + +, python e agora (talvez) em c #. Em todos esses, não tenho idéia de como inserir um blob em uma tabela. Como faço para armazenar e recuperar um blob no sqlite?

Veja como você pode fazê-lo em c #:

class Program { static void Main(string[] args) { if (File.Exists("test.db3")) { File.Delete("test.db3"); } using (var connection = new SQLiteConnection("Data Source=test.db3;Version=3")) using (var command = new SQLiteCommand("CREATE TABLE PHOTOS(ID INTEGER PRIMARY KEY AUTOINCREMENT, PHOTO BLOB)", connection)) { connection.Open(); command.ExecuteNonQuery(); byte[] photo = new byte[] { 1, 2, 3, 4, 5 }; command.CommandText = "INSERT INTO PHOTOS (PHOTO) VALUES (@photo)"; command.Parameters.Add("@photo", DbType.Binary, 20).Value = photo; command.ExecuteNonQuery(); command.CommandText = "SELECT PHOTO FROM PHOTOS WHERE ID = 1"; using (var reader = command.ExecuteReader()) { while (reader.Read()) { byte[] buffer = GetBytes(reader); } } } } static byte[] GetBytes(SQLiteDataReader reader) { const int CHUNK_SIZE = 2 * 1024; byte[] buffer = new byte[CHUNK_SIZE]; long bytesRead; long fieldOffset = 0; using (MemoryStream stream = new MemoryStream()) { while ((bytesRead = reader.GetBytes(0, fieldOffset, buffer, 0, buffer.Length)) > 0) { stream.Write(buffer, 0, (int)bytesRead); fieldOffset += bytesRead; } return stream.ToArray(); } } } 

Você precisa usar a interface de instruções preparadas do sqlite. Basicamente, a ideia é que você prepare uma declaração com um espaço reservado para o seu blob, então use uma das chamadas de binding para “ligar” seus dados …

Declarações Preparadas do SQLite

Acabei com esse método para inserir um blob:

  protected Boolean updateByteArrayInTable(String table, String value, byte[] byteArray, String expr) { try { SQLiteCommand mycommand = new SQLiteCommand(connection); mycommand.CommandText = "update " + table + " set " + value + "=@image" + " where " + expr; SQLiteParameter parameter = new SQLiteParameter("@image", System.Data.DbType.Binary); parameter.Value = byteArray; mycommand.Parameters.Add(parameter); int rowsUpdated = mycommand.ExecuteNonQuery(); return (rowsUpdated>0); } catch (Exception) { return false; } } 

Para ler de volta o código é:

  protected DataTable executeQuery(String command) { DataTable dt = new DataTable(); try { SQLiteCommand mycommand = new SQLiteCommand(connection); mycommand.CommandText = command; SQLiteDataReader reader = mycommand.ExecuteReader(); dt.Load(reader); reader.Close(); return dt; } catch (Exception) { return null; } } protected DataTable getAllWhere(String table, String sort, String expr) { String cmd = "select * from " + table; if (sort != null) cmd += " order by " + sort; if (expr != null) cmd += " where " + expr; DataTable dt = executeQuery(cmd); return dt; } public DataRow getImage(long rowId) { String where = KEY_ROWID_IMAGE + " = " + Convert.ToString(rowId); DataTable dt = getAllWhere(DATABASE_TABLE_IMAGES, null, where); DataRow dr = null; if (dt.Rows.Count > 0) // should be just 1 row dr = dt.Rows[0]; return dr; } public byte[] getImage(DataRow dr) { try { object image = dr[KEY_IMAGE]; if (!Convert.IsDBNull(image)) return (byte[])image; else return null; } catch(Exception) { return null; } } DataRow dri = getImage(rowId); byte[] image = getImage(dri); 

Isso funcionou bem para mim (c #):

 byte[] iconBytes = null; using (var dbConnection = new SQLiteConnection(DataSource)) { dbConnection.Open(); using (var transaction = dbConnection.BeginTransaction()) { using (var command = new SQLiteCommand(dbConnection)) { command.CommandText = "SELECT icon FROM my_table"; using (var reader = command.ExecuteReader()) { while (reader.Read()) { if (reader["icon"] != null && !Convert.IsDBNull(reader["icon"])) { iconBytes = (byte[]) reader["icon"]; } } } } transaction.Commit(); } } 

Não há necessidade de chunking. Apenas casting para uma matriz de bytes.

Como ainda não existe um exemplo completo para o C ++, é assim que você pode inserir e recuperar uma matriz / vetor de dados flutuantes sem verificação de erros:

 #include  #include  #include  int main() { // open sqlite3 database connection sqlite3* db; sqlite3_open("path/to/database.db", &db); // insert blob { sqlite3_stmt* stmtInsert = nullptr; sqlite3_prepare_v2(db, "INSERT INTO table_name (vector_blob) VALUES (?)", -1, &stmtInsert, nullptr); std::vector blobData(128); // your data sqlite3_bind_blob(stmtInsertFace, 1, blobData.data(), static_cast(blobData.size() * sizeof(float)), SQLITE_STATIC); if (sqlite3_step(stmtInsert) == SQLITE_DONE) std::cout < < "Insert successful" << std::endl; else std::cout << "Insert failed" << std::endl; sqlite3_finalize(stmtInsert); } // retrieve blob { sqlite3_stmt* stmtRetrieve = nullptr; sqlite3_prepare_v2(db, "SELECT vector_blob FROM table_name WHERE id = ?", -1, &stmtRetrieve, nullptr); int id = 1; // your id sqlite3_bind_int(stmtRetrieve, 1, id); std::vector blobData; if (sqlite3_step(stmtRetrieve) == SQLITE_ROW) { // retrieve blob data const float* pdata = reinterpret_cast(sqlite3_column_blob(stmtRetrieve, 0)); // query blob data size blobData.resize(sqlite3_column_bytes(stmtRetrieve, 0) / static_cast(sizeof(float))); // copy to data vector std::copy(pdata, pdata + static_cast(blobData.size()), blobData.data()); } sqlite3_finalize(stmtRetrieve); } sqlite3_close(db); return 0; } 

Em C ++ (sem verificação de erros):

 std::string blob = ...; // assume blob is in the string std::string query = "INSERT INTO foo (blob_column) VALUES (?);"; sqlite3_stmt *stmt; sqlite3_prepare_v2(db, query, query.size(), &stmt, nullptr); sqlite3_bind_blob(stmt, 1, blob.data(), blob.size(), SQLITE_TRANSIENT); 

Isso pode ser SQLITE_STATIC se a consulta for executada antes de o blob ser destruído .