Come inserire bulk con SQLite?

Question

Come inserire bulk con SQLite?

L'ho cercato e mi sembra di inserire un inserto con un'istruzione select. Ho cercato su Google, ho esaminato gli esempi e sembrano tutti copiati da una tabella a un'altra o non sono compatibili con SQLite. Voglio fare qualcosa di simile

"INSERT INTO user_msg_media (recipientId, mediaId, catagory, current_media_date) " + 
"VALUES(@mediaId, @catagory, @current_media_date)"; 
where the value of recipientId is the watcher from each of 
"SELECT watcher FROM userwatch WHERE watched=@watched"; 

Ho provato il codice qui sotto e ottengo l'errore "errore di SQLite tale colonna: watcher"

 command.CommandText = 
      "CREATE TABLE if not exists user_msg_media(" + 
      "msgId  INTEGER PRIMARY KEY, " + 
      "recipientId INTEGER, " + 
      "mediaId  INTEGER, " + 
      "catagory  INTEGER, " + 
      "current_date DATE);"; 
     command.ExecuteNonQuery(); 

     //user media 
     command.CommandText = 
      "CREATE TABLE if not exists user_watch(" + 
      "indx INTEGER PRIMARY KEY, " + 
      "watcher INTEGER, " + 
      "watched INTEGER);"; 
     command.ExecuteNonQuery(); 
     //... 

    command.CommandText = "SELECT watcher FROM user_watch WHERE watched=:watched;"; 
    command.Parameters.Add(":watched", DbType.Int64).Value = 1; 
    command.ExecuteNonQuery(); //is ok 

    command.CommandText = 
     "INSERT INTO user_msg_media (recipientId, mediaId, catagory, current_media_date) " + 
     "SELECT watcher, :mediaId, :category, :current_media_date" + 
     "FROM user_watch WHERE watched=:watched;"; 
    command.Parameters.Add(":mediaId", DbType.Int64).Value = 0; 
    command.Parameters.Add(":category", DbType.Int64).Value = 0; 
    command.Parameters.Add(":current_media_date", DbType.Int64).Value = 0; 
    command.Parameters.Add(":watched", DbType.Int64).Value = 1; 
    command.ExecuteNonQuery(); 

Answer 1

SQLite non supporta la notazione @variable, ma (utilizzando lo stile di nome-segnaposto come sostenuto dalla Python legame di SQLite per chiarezza) questo dovrebbe funzionare:

INSERT INTO user_msg_media (userId, mediaId, catagory, current_media_date) 
SELECT watcher, :mediaId, :category, :current_media_date 
FROM userwatch WHERE watched=:watched 

Edit: SQLite sembra essere misdiagnosing quale colonna nome è sbagliato. Con i nomi di colonna tutti i fissi, il seguente codice Python funziona per me (non so cosa altra lingua si sta utilizzando, Python di quello più comodo per me di interagire con SQLite):

import sqlite3 as sq 

con = sq.connect(':memory:') 
cur = con.cursor() 
cur.execute("CREATE TABLE if not exists user_msg_media(" + 
      "msgId  INTEGER PRIMARY KEY, " + 
      "recipientId INTEGER, " + 
      "mediaId  INTEGER, " + 
      "catagory  INTEGER, " + 
      "current_date DATE)") 
cur.execute("CREATE TABLE if not exists user_watch(" + 
      "indx INTEGER PRIMARY KEY, " + 
      "watcher INTEGER, " + 
      "watched INTEGER)") 

cur.execute("INSERT INTO user_watch VALUES (1, 2, 3)") 

cur.execute("SELECT watcher FROM user_watch WHERE watched=:watched", 
      dict(watched=3)) 
print cur.fetchall() 

print cur.execute("INSERT INTO user_msg_media (recipientId, mediaId, catagory, current_date) " + 
     "SELECT watcher, :mediaId, :category, :current_media_date " + 
     "FROM user_watch WHERE watched=:watched;", 
     dict(mediaId=0, category=0, current_media_date=0, watched=3) 
) 

cur.execute("SELECT * FROM user_msg_media") 
print cur.fetchall() 

Ma se ho riprodotto disallineamenti di SQL come current_date vs current_media_date, posso far diagnosticare erroneamente che la colonna mancante sia watcher, anche se quella colonna è di fatto valida. Vuoi provare a inserire questo codice corretto nella tua lingua preferita e vedere come si comporta?

Answer 2

Ho scritto una classe per facilitare gli inserimenti di massa in SQLite. Speriamo che sia utile:

http://procbits.com/2009/09/08/sqlite-bulk-insert/

-JP

Answer 3

Io suggerirei di usare Dapper ORM da parte dei nostri amici a StackOverflow. Se guardi la sezione sul rendimento, non puoi ottenere molto più velocemente di Dapper.

eseguire un comando più volte
la stessa firma permette inoltre di comodo ed efficiente eseguire un comando più volte (ad esempio per i dati bulk-carico)

Esempio utilizzo:

connection.Execute(@"insert MyTable(colA, colB) values (@a, @b)", 
    new[] { new { a=1, b=1 }, new { a=2, b=2 }, new { a=3, b=3 } } 
); // 3 rows inserted: "1,1", "2,2" and "3,3" 

Funziona per qualsiasi parametro che implementa IEnumerable per alcuni T.