You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
79 lines
3.2 KiB
79 lines
3.2 KiB
/*
|
|
* This file is part of Airsonic.
|
|
*
|
|
* Airsonic is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Airsonic is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with Airsonic. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
* Copyright 2015 (C) Sindre Mehus
|
|
*/
|
|
package org.airsonic.player.dao;
|
|
|
|
import org.airsonic.player.domain.PlayQueue;
|
|
import org.airsonic.player.domain.SavedPlayQueue;
|
|
import org.springframework.jdbc.core.RowMapper;
|
|
import org.springframework.stereotype.Repository;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
import java.sql.ResultSet;
|
|
import java.sql.SQLException;
|
|
import java.util.List;
|
|
|
|
/**
|
|
* Provides database services for play queues
|
|
*
|
|
* @author Sindre Mehus
|
|
*/
|
|
@Repository
|
|
public class PlayQueueDao extends AbstractDao {
|
|
|
|
private static final String INSERT_COLUMNS = "username, current, position_millis, changed, changed_by";
|
|
private static final String QUERY_COLUMNS = "id, " + INSERT_COLUMNS;
|
|
private final RowMapper<SavedPlayQueue> rowMapper = new PlayQueueMapper();
|
|
|
|
@Transactional
|
|
public SavedPlayQueue getPlayQueue(String username) {
|
|
SavedPlayQueue playQueue = queryOne("select " + QUERY_COLUMNS + " from play_queue where username=?", rowMapper, username);
|
|
if (playQueue == null) {
|
|
return null;
|
|
}
|
|
List<Integer> mediaFileIds = queryForInts("select media_file_id from play_queue_file where play_queue_id = ?", playQueue.getId());
|
|
playQueue.setMediaFileIds(mediaFileIds);
|
|
return playQueue;
|
|
}
|
|
|
|
@Transactional
|
|
public void savePlayQueue(SavedPlayQueue playQueue) {
|
|
update("delete from play_queue where username=?", playQueue.getUsername());
|
|
update("insert into play_queue(" + INSERT_COLUMNS + ") values (" + questionMarks(INSERT_COLUMNS) + ")",
|
|
playQueue.getUsername(), playQueue.getCurrentMediaFileId(), playQueue.getPositionMillis(),
|
|
playQueue.getChanged(), playQueue.getChangedBy());
|
|
int id = queryForInt("select max(id) from play_queue", 0);
|
|
playQueue.setId(id);
|
|
|
|
for (Integer mediaFileId : playQueue.getMediaFileIds()) {
|
|
update("insert into play_queue_file(play_queue_id, media_file_id) values (?, ?)", id, mediaFileId);
|
|
}
|
|
}
|
|
|
|
private static class PlayQueueMapper implements RowMapper<SavedPlayQueue> {
|
|
public SavedPlayQueue mapRow(ResultSet rs, int rowNum) throws SQLException {
|
|
return new SavedPlayQueue(rs.getInt(1),
|
|
rs.getString(2),
|
|
null,
|
|
rs.getInt(3),
|
|
rs.getLong(4),
|
|
rs.getTimestamp(5),
|
|
rs.getString(6));
|
|
}
|
|
}
|
|
}
|
|
|