public class JDBCRatingDAO extends Object implements EventDAO, UserEventDAO, ItemEventDAO, UserDAO, ItemDAO
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
closeConnection |
static int |
COL_ITEM_ID
Item ID column number.
|
static int |
COL_RATING
Rating column number.
|
static int |
COL_TIMESTAMP
Timestamp column number.
|
static int |
COL_USER_ID
User ID column number.
|
protected Connection |
connection |
protected org.slf4j.Logger |
logger |
| Constructor and Description |
|---|
JDBCRatingDAO(Connection dbc,
SQLStatementFactory sfac)
Deprecated.
Use
newBuilder(). |
JDBCRatingDAO(Connection dbc,
SQLStatementFactory sfac,
boolean close)
Deprecated.
Use
newBuilder(). |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the connection and all open statements.
|
List<Event> |
getEventsForItem(long itemId)
Get the events for a specific item.
|
<E extends Event> |
getEventsForItem(long iid,
Class<E> type)
Get the events for a specific item, filtering by type.
|
UserHistory<Event> |
getEventsForUser(long userId)
Get the events for a specific user.
|
<E extends Event> |
getEventsForUser(long uid,
Class<E> type)
Get the events for a specific user, filtering by type.
|
protected LongSet |
getIdSet(PreparedStatement s) |
LongSet |
getItemIds()
Get all known item IDs.
|
LongSet |
getUserIds()
Get all known user IDs.
|
LongSet |
getUsersForItem(long item)
Get the users who have interacted with an item.
|
static JDBCRatingDAOBuilder |
newBuilder()
Create a new JDBC DAO builder.
|
Cursor<Event> |
streamEvents()
Stream all events.
|
<E extends Event> |
streamEvents(Class<E> type)
Stream all events of a given type.
|
<E extends Event> |
streamEvents(Class<E> type,
SortOrder order)
Stream all events of a given type in a specified order.
|
Cursor<ItemEventCollection<Event>> |
streamEventsByItem()
Stream events grouped by item.
|
<E extends Event> |
streamEventsByItem(Class<E> type)
Stream events grouped by item.
|
Cursor<UserHistory<Event>> |
streamEventsByUser()
Stream events grouped by user.
|
<E extends Event> |
streamEventsByUser(Class<E> type)
Stream events grouped by user.
|
public static final int COL_USER_ID
public static final int COL_ITEM_ID
public static final int COL_RATING
public static final int COL_TIMESTAMP
protected final org.slf4j.Logger logger
protected final Connection connection
protected final boolean closeConnection
@Deprecated public JDBCRatingDAO(@WillCloseWhenClosed Connection dbc, SQLStatementFactory sfac)
newBuilder().dbc - The database connection. The connection will be closed
when the DAO is closed.sfac - The statement factory.@Deprecated public JDBCRatingDAO(Connection dbc, SQLStatementFactory sfac, boolean close)
newBuilder().dbc - The database connection.sfac - The statement factory.close - Whether to close the database connection when the DAO is closed.public static JDBCRatingDAOBuilder newBuilder()
public void close()
protected LongSet getIdSet(PreparedStatement s) throws SQLException
SQLExceptionpublic LongSet getUserIds()
UserDAOgetUserIds in interface UserDAOpublic LongSet getItemIds()
ItemDAOgetItemIds in interface ItemDAOpublic Cursor<Event> streamEvents()
EventDAOstreamEvents in interface EventDAOpublic <E extends Event> Cursor<E> streamEvents(Class<E> type)
EventDAOstreamEvents in interface EventDAOtype - The event type.public <E extends Event> Cursor<E> streamEvents(Class<E> type, SortOrder order)
EventDAOstreamEvents in interface EventDAOtype - The event type.order - The order.public UserHistory<Event> getEventsForUser(long userId)
UserEventDAOgetEventsForUser in interface UserEventDAOuserId - The user ID.null if the user is unknown.public <E extends Event> UserHistory<E> getEventsForUser(long uid, Class<E> type)
UserEventDAOgetEventsForUser in interface UserEventDAOuid - The user ID.type - The type of events to retrieve.null if the user is unknown.public List<Event> getEventsForItem(long itemId)
ItemEventDAOgetEventsForItem in interface ItemEventDAOitemId - The item ID.null if the item is unknown.public <E extends Event> List<E> getEventsForItem(long iid, Class<E> type)
ItemEventDAOgetEventsForItem in interface ItemEventDAOiid - The item ID.type - The type of events to retrieve.null if the item is unknown.public LongSet getUsersForItem(long item)
ItemEventDAOgetUsersForItem in interface ItemEventDAOitem - The item ID.null if the item
is unknown.public Cursor<UserHistory<Event>> streamEventsByUser()
UserEventDAOstreamEventsByUser in interface UserEventDAOpublic <E extends Event> Cursor<UserHistory<E>> streamEventsByUser(Class<E> type)
UserEventDAOstreamEventsByUser in interface UserEventDAOtype - The type of item to look for.type. If a
user exists, but does not have any history, they may or may not be included depending
on the DAO implementation.public Cursor<ItemEventCollection<Event>> streamEventsByItem()
ItemEventDAOstreamEventsByItem in interface ItemEventDAOpublic <E extends Event> Cursor<ItemEventCollection<E>> streamEventsByItem(Class<E> type)
ItemEventDAOstreamEventsByItem in interface ItemEventDAOtype - The type of item to look for.type from all items. If an item
exists but does not have any events, it may or may not be included depending on the
DAO implementation.