/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, UserEntity entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } stmt.bindLong(2, entity.getPeerId()); stmt.bindLong(3, entity.getGender()); stmt.bindString(4, entity.getMainName()); stmt.bindString(5, entity.getPinyinName()); stmt.bindString(6, entity.getRealName()); stmt.bindString(7, entity.getAvatar()); stmt.bindString(8, entity.getPhone()); stmt.bindString(9, entity.getEmail()); stmt.bindLong(10, entity.getDepartmentId()); stmt.bindLong(11, entity.getStatus()); stmt.bindLong(12, entity.getCreated()); stmt.bindLong(13, entity.getUpdated()); }
@Test public void executeInsertWithArgsThrowsAndDoesNotTrigger() { SQLiteStatement statement = real.compileStatement("INSERT INTO " + TABLE_EMPLOYEE + " (" + NAME + ", " + USERNAME + ") VALUES (?, ?)"); statement.bindString(1, "Alice Aliison"); statement.bindString(2, "alice"); db.createQuery(TABLE_EMPLOYEE, SELECT_EMPLOYEES) .skip(1) // Skip initial .subscribe(o); try { db.executeInsert(TABLE_EMPLOYEE, statement); fail(); } catch (SQLException ignored) { } o.assertNoMoreEvents(); }
public Uri insert(Uri uri, ContentValues values) { SQLiteDatabase sqlDb = dbHelper.getWritableDatabase(); List<String> segments = uri.getPathSegments(); String recordId = segments.get(1); String name = segments.get(3); String insertView = "Insert or replace into views (record_id, name, query, date_synced) values(?,?,?,?)"; SQLiteStatement insertViewStmt = sqlDb.compileStatement(insertView); insertViewStmt.bindString(1, recordId); insertViewStmt.bindString(2, name); insertViewStmt.bindString(3, values.getAsString("query")); insertViewStmt.bindString(4, values.getAsString("date_synced")); insertViewStmt.execute(); getContext() .getContentResolver() .notifyChange(uri, null); return uri; }
@Override public int executeUpdateDelete(SqlInfo sqlInfo) throws DbException { SQLiteStatement statement = null; try { statement = sqlInfo.buildStatement(database); return statement.executeUpdateDelete(); } catch (Throwable e) { throw new DbException(e); } finally { if (statement != null) { try { statement.releaseReference(); } catch (Throwable ex) { LogUtil.e(ex.getMessage(), ex); } } } }
@Override protected final void bindValues(SQLiteStatement stmt, Bpm entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } String mBpm = entity.getMBpm(); if (mBpm != null) { stmt.bindString(2, mBpm); } String mTime = entity.getMTime(); if (mTime != null) { stmt.bindString(3, mTime); } String mDescription = entity.getMDescription(); if (mDescription != null) { stmt.bindString(4, mDescription); } }
@Override protected final void bindValues(SQLiteStatement stmt, ToManyTargetEntity entity) { stmt.clearBindings(); Long toManyId = entity.getToManyId(); if (toManyId != null) { stmt.bindLong(1, toManyId); } Long toManyIdDesc = entity.getToManyIdDesc(); if (toManyIdDesc != null) { stmt.bindLong(2, toManyIdDesc); } Long id = entity.getId(); if (id != null) { stmt.bindLong(3, id); } String targetJoinProperty = entity.getTargetJoinProperty(); if (targetJoinProperty != null) { stmt.bindString(4, targetJoinProperty); } }
@TargetApi(Build.VERSION_CODES.HONEYCOMB) @SdkSuppress(minSdkVersion = Build.VERSION_CODES.HONEYCOMB) @Test public void executeUpdateDeleteThrowsAndDoesNotTrigger() { SQLiteStatement statement = real.compileStatement( "UPDATE " + TABLE_EMPLOYEE + " SET " + USERNAME + " = 'alice'"); db.createQuery(TABLE_EMPLOYEE, SELECT_EMPLOYEES) .skip(1) // Skip initial .subscribe(o); try { db.executeUpdateDelete(TABLE_EMPLOYEE, statement); fail(); } catch (SQLException ignored) { } o.assertNoMoreEvents(); }
@TargetApi(Build.VERSION_CODES.HONEYCOMB) @SdkSuppress(minSdkVersion = Build.VERSION_CODES.HONEYCOMB) @Test public void executeUpdateDeleteAndTriggerWithNoTables() { SQLiteStatement statement = real.compileStatement( "UPDATE " + TABLE_EMPLOYEE + " SET " + NAME + " = 'Zach'"); db.createQuery(TABLE_EMPLOYEE, SELECT_EMPLOYEES).subscribe(o); o.assertCursor() .hasRow("alice", "Alice Allison") .hasRow("bob", "Bob Bobberson") .hasRow("eve", "Eve Evenson") .isExhausted(); db.executeUpdateDelete(Collections.<String>emptySet(), statement); o.assertNoMoreEvents(); }
@Override protected final void bindValues(SQLiteStatement stmt, User entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } String phone = entity.getPhone(); if (phone != null) { stmt.bindString(2, phone); } String psw = entity.getPsw(); if (psw != null) { stmt.bindString(3, psw); } }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, SessionEntity entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } stmt.bindString(2, entity.getSessionKey()); stmt.bindLong(3, entity.getPeerId()); stmt.bindLong(4, entity.getPeerType()); stmt.bindLong(5, entity.getLatestMsgType()); stmt.bindLong(6, entity.getLatestMsgId()); stmt.bindString(7, entity.getLatestMsgData()); stmt.bindLong(8, entity.getTalkId()); stmt.bindLong(9, entity.getCreated()); stmt.bindLong(10, entity.getUpdated()); }
SQLiteStatement createInsertStatement(SQLiteDatabase database) { return database.compileStatement("INSERT INTO " + TABLE_NAME + " (" + ADDRESS + ", " + PERSON + ", " + DATE_SENT + ", " + DATE_RECEIVED + ", " + PROTOCOL + ", " + READ + ", " + STATUS + ", " + TYPE + ", " + REPLY_PATH_PRESENT + ", " + SUBJECT + ", " + BODY + ", " + SERVICE_CENTER + ", " + THREAD_ID + ") " + " VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"); }
@Override protected final void bindValues(SQLiteStatement stmt, County entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } String countyName = entity.getCountyName(); if (countyName != null) { stmt.bindString(2, countyName); } String weatherId = entity.getWeatherId(); if (weatherId != null) { stmt.bindString(3, weatherId); } stmt.bindLong(4, entity.getCityId()); }
@Test public void executeInsertThrowsAndDoesNotTrigger() { SQLiteStatement statement = real.compileStatement("INSERT INTO " + TABLE_EMPLOYEE + " (" + NAME + ", " + USERNAME + ") " + "VALUES ('Alice Allison', 'alice')"); db.createQuery(TABLE_EMPLOYEE, SELECT_EMPLOYEES) .skip(1) // Skip initial .subscribe(o); try { db.executeInsert(TABLE_EMPLOYEE, statement); fail(); } catch (SQLException ignored) { } o.assertNoMoreEvents(); }
public int createItem(int list_id, String label) { Log.v(L.TAG, "DataManager.createItem(): Insert item " + label); SQLiteDatabase db = helper.getWritableDatabase(); SQLiteStatement stmt = db.compileStatement("insert into items (list_id,label,active) values (?,?,?)"); stmt.bindLong(1, list_id); stmt.bindString(2, label); stmt.bindLong(3, 1); long id = stmt.executeInsert(); stmt.close(); db.close(); Log.d(L.TAG, "DataManager.createItem(): Inserted item and got id " + id); if(id == -1) { Log.e(L.TAG, "DataManager.createItem(): Attempt to insert item failed. Got " + id + " from executeInsert()"); } return (int)id; }
private void bind(int index, Object value, SQLiteStatement sQLiteStatement) { if (value == null) { sQLiteStatement.bindNull(index); } else { int i = Arrays.binarySearch(TYPES_ADD, TypeUtil.Type.forSearch(value.getClass())); if (i >= 0) { TypeUtil.Type<TypeUtil.StatementObj> type = TYPES_MULTI_ADD[i]; type.put(null, value, new TypeUtil.StatementObj(index, sQLiteStatement)); } else { throw new DBException("unknown type of " + value.getClass() + " for sqlite"); } } }
@Override public int del(Condition query) throws DBException { SQLiteStatement statement = null; try { SqlUtil.WhereSQL whereSQL = SqlUtil.toDelete(tableName, checkCondition(query), true); statement = db.compileStatement(whereSQL.sql); Object[] args = whereSQL.args; for (int i = 0; i < args.length; i++) { bind(i + 1, args[i], statement); } return statement.executeUpdateDelete(); } catch (Exception e) { throw new DBException(e); } finally { close(statement); } }
public void deleteCategories(@NonNull List<Category> categories) { if (!openDatabase()) { LogUtil.e("Database error: deleteCategories() failed to open database"); return; } String query = "DELETE FROM " +TABLE_CATEGORIES+ " WHERE " +KEY_NAME+ " = ?"; SQLiteStatement statement = mDatabase.get().mSQLiteDatabase.compileStatement(query); mDatabase.get().mSQLiteDatabase.beginTransaction(); for (Category category : categories) { statement.clearBindings(); statement.bindString(1, category.getName()); statement.execute(); } mDatabase.get().mSQLiteDatabase.setTransactionSuccessful(); mDatabase.get().mSQLiteDatabase.endTransaction(); }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, ContactLink entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } Long BUserDaoId = entity.getBUserDaoId(); if (BUserDaoId != null) { stmt.bindLong(2, BUserDaoId); } Long linkOwnerBUserDaoId = entity.getLinkOwnerBUserDaoId(); if (linkOwnerBUserDaoId != null) { stmt.bindLong(3, linkOwnerBUserDaoId); } }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, UserThreadLink entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } Long BUserDaoId = entity.getBUserDaoId(); if (BUserDaoId != null) { stmt.bindLong(2, BUserDaoId); } Long BThreadDaoId = entity.getBThreadDaoId(); if (BThreadDaoId != null) { stmt.bindLong(3, BThreadDaoId); } }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, FollowerLink entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } Integer type = entity.getType(); if (type != null) { stmt.bindLong(2, type); } Long BUserDaoId = entity.getBUserDaoId(); if (BUserDaoId != null) { stmt.bindLong(3, BUserDaoId); } Long linkOwnerBUserDaoId = entity.getLinkOwnerBUserDaoId(); if (linkOwnerBUserDaoId != null) { stmt.bindLong(4, linkOwnerBUserDaoId); } }
static void addAll(SQLiteDatabase database, List<OpenLocateLocation> locations) { if (database == null || locations == null || locations.isEmpty()) { return; } SQLiteStatement statement = database.compileStatement(BULK_INSERT_LOCATION); database.beginTransaction(); for (OpenLocateLocation location : locations) { statement.clearBindings(); statement.bindString(COLUMN_LOCATION_INDEX, location.getJson().toString()); statement.bindLong(2, location.getCreated().getTime()); statement.execute(); } database.setTransactionSuccessful(); database.endTransaction(); }
private long performGetLength() { SQLiteDatabase database = mDatabaseSupplier.getDatabase(); if (database == null) { return 0; } String sql = "SELECT count(" + WXSQLiteOpenHelper.COLUMN_KEY + ") FROM " + WXSQLiteOpenHelper.TABLE_STORAGE; SQLiteStatement statement = null; try { statement = database.compileStatement(sql); return statement.simpleQueryForLong(); } catch (Exception e) { WXLogUtils.e(WXSQLiteOpenHelper.TAG_STORAGE, "DefaultWXStorage occurred an exception when execute getLength:" + e.getMessage()); return 0; } finally { if(statement != null) { statement.close(); } } }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, PhotoItem entity) { stmt.clearBindings(); int c = 0; Long id = entity.getId(); ++c; if (id != null) { stmt.bindLong(c, id); } ++c; stmt.bindString(c, handleNull(entity.get_id())); ++c; stmt.bindString(c, handleNull(entity.getName())); ++c; stmt.bindString(c, handleNull(entity.getPath())); ++c; stmt.bindString(c, handleNull(entity.getTag())); ++c; stmt.bindLong(c, entity.isStatus()?1:0); }
@TargetApi(Build.VERSION_CODES.HONEYCOMB) @SdkSuppress(minSdkVersion = Build.VERSION_CODES.HONEYCOMB) @Test public void executeUpdateDeleteAndDontTrigger() { SQLiteStatement statement = real.compileStatement("" + "UPDATE " + TABLE_EMPLOYEE + " SET " + NAME + " = 'Zach'" + " WHERE " + NAME + " = 'Rob'"); db.createQuery(TABLE_EMPLOYEE, SELECT_EMPLOYEES).subscribe(o); o.assertCursor() .hasRow("alice", "Alice Allison") .hasRow("bob", "Bob Bobberson") .hasRow("eve", "Eve Evenson") .isExhausted(); db.executeUpdateDelete(TABLE_EMPLOYEE, statement); o.assertNoMoreEvents(); }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, BLinkedAccount entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } String Token = entity.getToken(); if (Token != null) { stmt.bindString(2, Token); } Integer type = entity.getType(); if (type != null) { stmt.bindLong(3, type); } Long BUserDaoId = entity.getBUserDaoId(); if (BUserDaoId != null) { stmt.bindLong(4, BUserDaoId); } }
@Override protected final void bindValues(SQLiteStatement stmt, UserBean entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } stmt.bindString(2, entity.getTitle()); stmt.bindString(3, entity.getFirst()); stmt.bindString(4, entity.getLast()); stmt.bindString(5, entity.getEmail()); stmt.bindString(6, entity.getDob()); stmt.bindString(7, entity.getPhone()); stmt.bindString(8, entity.getCell()); stmt.bindString(9, entity.getThumbnailPic()); stmt.bindString(10, entity.getMediumPic()); stmt.bindString(11, entity.getLargePic()); }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, BlackList entity) { stmt.clearBindings(); stmt.bindString(1, entity.getUserId()); String status = entity.getStatus(); if (status != null) { stmt.bindString(2, status); } Long timestamp = entity.getTimestamp(); if (timestamp != null) { stmt.bindLong(3, timestamp); } }
@Override protected final void bindValues(SQLiteStatement stmt, LocalUser entity) { stmt.clearBindings(); stmt.bindString(1, entity.getLogin()); String name = entity.getName(); if (name != null) { stmt.bindString(2, name); } String avatarUrl = entity.getAvatarUrl(); if (avatarUrl != null) { stmt.bindString(3, avatarUrl); } Integer followers = entity.getFollowers(); if (followers != null) { stmt.bindLong(4, followers); } Integer following = entity.getFollowing(); if (following != null) { stmt.bindLong(5, following); } }
public void updateItemStarness(int itemId, boolean star) { Log.d(L.TAG, "Setting star property of " + itemId + " to " + star); SQLiteDatabase db = helper.getWritableDatabase(); SQLiteStatement stmt = db.compileStatement("update items set star=? where id=?"); stmt.bindLong(1, star?1:0); stmt.bindLong(2, itemId); stmt.execute(); stmt.close(); db.close(); }
private static void addTranslatedTypeToStatement(SQLiteStatement statement, Cursor cursor, int index, String key) { int columnIndex = cursor.getColumnIndexOrThrow(key); if (cursor.isNull(columnIndex)) { statement.bindLong(index, SmsDatabase.Types.BASE_INBOX_TYPE | SmsDatabase.Types.ENCRYPTION_SYMMETRIC_BIT); } else { long theirType = cursor.getLong(columnIndex); statement.bindLong(index, SmsDatabase.Types.translateFromSystemBaseType(theirType) | SmsDatabase.Types.ENCRYPTION_SYMMETRIC_BIT); } }
protected void updateInsideSynchronized(T entity, SQLiteStatement stmt, boolean lock) { // To do? Check if it's worth not to bind PKs here (performance). bindValues(stmt, entity); int index = config.allColumns.length + 1; K key = getKey(entity); if (key instanceof Long) { stmt.bindLong(index, (Long) key); } else if (key == null) { throw new DaoException("Cannot update entity without key - was it inserted before?"); } else { stmt.bindString(index, key.toString()); } stmt.execute(); attachEntity(key, entity, lock); }
private static void insertUser(@NonNull SQLiteStatement statement, @NonNull User user) { InsertSqlStatementBinder .startBind(statement) .bindLong(user.getId()) .bindString(user.getName()) .bindStringEmptySafe(user.getSecondName()) .bindString(user.getEmail()) .bindDate(user.getBirthday()) .executeInsert(); }
public void InsertToSqlite(String imei, String latitude, String longitude, String out) { SQLiteStatement statement = localdb.compileStatement("INSERT INTO position VALUES(?,?,?,datetime(),?)"); statement.bindString(1, imei); statement.bindString(2, latitude); statement.bindString(3, longitude); statement.bindString(4, out); statement.executeInsert(); statement.close(); }
@Override protected final void bindValues(SQLiteStatement stmt, CustomTypeEntity entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } MyTimestamp myCustomTimestamp = entity.getMyCustomTimestamp(); if (myCustomTimestamp != null) { stmt.bindLong(2, myCustomTimestampConverter.convertToDatabaseValue(myCustomTimestamp)); } }
@Override protected final void bindValues(SQLiteStatement stmt, ExtendsImplementsEntity entity) { stmt.clearBindings(); Long id = entity.getId(); if (id != null) { stmt.bindLong(1, id); } String text = entity.getText(); if (text != null) { stmt.bindString(2, text); } }
@Override protected final void bindValues(SQLiteStatement stmt, StringKeyValueEntity entity) { stmt.clearBindings(); String key = entity.getKey(); if (key != null) { stmt.bindString(1, key); } String value = entity.getValue(); if (value != null) { stmt.bindString(2, value); } }
/** @inheritdoc */ @Override protected void bindValues(SQLiteStatement stmt, RestaurantImage entity) { stmt.clearBindings(); int c = 0; Long id = entity.getId(); ++c; if (id != null) { stmt.bindLong(c, id); } ++c; stmt.bindString(c, handleNull(entity.getRestaurant_id())); ++c; stmt.bindString(c, handleNull(entity.getRestaurant_branch_id())); ++c; stmt.bindString(c, handleNull(entity.getImage())); }
public void saveLive(List<LivePvDatum> livePvData) { SQLiteDatabase db = pvDataHelper.getWritableDatabase(); db.beginTransaction(); String sql = "REPLACE INTO " + PvDataContract.LivePvData.TABLE_NAME + "(" + PvDataContract.LivePvData.COLUMN_NAME_YEAR + "," + PvDataContract.LivePvData.COLUMN_NAME_MONTH + "," + PvDataContract.LivePvData.COLUMN_NAME_DAY + "," + PvDataContract.LivePvData.COLUMN_NAME_HOUR + "," + PvDataContract.LivePvData.COLUMN_NAME_MINUTE + "," + PvDataContract.LivePvData.COLUMN_NAME_ENERGY_GENERATION + "," + PvDataContract.LivePvData.COLUMN_NAME_POWER_GENERATION + ") VALUES (?,?,?,?,?,?,?);"; SQLiteStatement statement = db.compileStatement(sql); double maxPowerGeneration = Double.MIN_VALUE; for (LivePvDatum livePvDatum : livePvData) { statement.clearBindings(); statement.bindLong(1, livePvDatum.getYear()); statement.bindLong(2, livePvDatum.getMonth()); statement.bindLong(3, livePvDatum.getDay()); statement.bindLong(4, livePvDatum.getHour()); statement.bindLong(5, livePvDatum.getMinute()); statement.bindDouble(6, livePvDatum.getEnergyGeneration()); statement.bindDouble(7, livePvDatum.getPowerGeneration()); statement.execute(); maxPowerGeneration = Math.max(maxPowerGeneration, livePvDatum.getPowerGeneration()); } db.setTransactionSuccessful(); db.endTransaction(); db.close(); Log.d(TAG, "Saved " + livePvData.size() + " rows of live PV data to database"); RecordPvDatum recordPvDatum = loadRecord(); if (maxPowerGeneration > recordPvDatum.getLivePowerGeneration()) { recordPvDatum.setLivePowerGeneration(maxPowerGeneration); saveRecord(recordPvDatum); } }
public long getIDByIndex(int index) { SQLiteStatement downloadByIndex = getDownloadByIndexStatement(); downloadByIndex.clearBindings(); downloadByIndex.bindLong(1, index); try { return downloadByIndex.simpleQueryForLong(); } catch (SQLiteDoneException e) { return -1; } }
private void createFiles(SQLiteDatabase db) { mFileNames = new String[mFiles]; byte[] rawData = new byte[mFileSize+mFiles]; Random random = new Random(); random.nextBytes(rawData); ByteArrayOutputStream[] streams = new ByteArrayOutputStream[mFiles]; for (int i = 0; i < mFiles; i++) { streams[i] = new ByteArrayOutputStream(mFileSize); streams[i].write(rawData, i, mFileSize); mFileNames[i] = String.valueOf(i); } SQLiteStatement insert = db.compileStatement("INSERT INTO files (filename, data) VALUES (?, ?)"); for (int i = 0; i < mFiles; i++) { insert.bindString(1, mFileNames[i]); insert.bindBlob(2, streams[i].toByteArray()); insert.execute(); } }