#java #mysql #jpa #join #orm
#java #mysql #jpa #Присоединиться #orm
Вопрос:
Хорошо, это может показаться глупым, но я новичок в MySQL, поэтому я действительно понятия не имею, относится ли это к объединениям или чему-то еще.
Итак, у меня есть 3 таблицы: СООБЩЕНИЕ, ПОЛЬЗОВАТЕЛЬ, ЛАЙКИ. В основном они имеют:
POST
post_id | caption | media | ...
USER
user_id | name | email | ...
LIKES
like_id | post_id | user_id | ...
И объекты в Java являются:
@Entity
@Table(name="POST")
public class PostMW{
@Id
@Column(name="id", nullable=false)
@GeneratedValue(strategy=GenerationType.AUTO)
private Long id;
@OneToOne(cascade = CascadeType.ALL)
@JoinColumn(name="media_id", nullable=false, unique=true)
private MediaMW media;
....
@Transient
private Boolean liked;
}
И ЛАЙКИ:
@Entity
@Table(name="LIKES")
public class LikeMW {
@Id
@Column(name="id", nullable=false)
@GeneratedValue(strategy=GenerationType.AUTO)
private Long id;
@ManyToOne(cascade = CascadeType.ALL)
@JoinColumn(name = "post_id", nullable=false)
@JsonBackReference
private PostMW post;
@ManyToOne(cascade = CascadeType.ALL)
@JoinColumn(name="user_id", nullable=false)
private UserMW user;
}
ПОЛЬЗОВАТЕЛЬ может запросить список сообщений, поэтому мне нужно установить свойство «понравилось» для КАЖДОГО СООБЩЕНИЯ, если оно понравилось этому ПОЛЬЗОВАТЕЛЮ.
До сих пор я делал:
public class FeedServiceImpl implements FeedService{
private PostDao<PostMW, Long> postDao;
...
@Override
public List<PostMW> getFeed(int page, UserMW user) {
List<PostMW> resu<
int offset = page * ConstUtil.FEED_POSTS_PER_PAGE;
postDao.openCurrentSession();
result = postDao.list(offset, ConstUtil.FEED_POSTS_PER_PAGE);
for(PostMW post : result){
//TODO
//post.setLiked(postDao.postLikedByUser(post, user));
//PS
// FOR EVERY POST I'M EXECUTING THE QUERY BELOW
//@NamedQuery(name="isLiked", query="SELECT COUNT(likes.id) FROM
//LikeMW likes WHERE likes.post.id = :postID AND likes.user.id = :userID"),
}
postDao.closeCurrentSession();
return resu<
}
...
}
I don’t even know if it works cause I really don’t like the idea to retrieve for example 100 posts and inside a loop, make 100 requests in a row just to check if the user liked that post or not so I didn’t even try.
So, what should I do? Any suggestion would be very appreciate!!
Thanks!
EDIT:
Trying this query at moment:
List<Object> result = entityManager
.createQuery("SELECT post FROM PostMW post LEFT OUTER JOIN post.hasLiked liked ON post.id = liked.post_id AND liked.user_id =:userID")
.setParameter("userID", 1)
.setFirstResult(offset).setMaxResults(itemsPerPage)
.getResultList();
Обновил мои объекты. Теперь мой объект PostMW имеет
@Entity
@Table(name="POST")
public class PostMW{
...
@ManyToMany(cascade = CascadeType.ALL)
@JoinTable(name="LIKES", joinColumns=@JoinColumn(name="post_id"), inverseJoinColumns=@JoinColumn(name="user_id"))
private List<UserMW> hasLiked;
...
}
И UserMW имеет
@Entity
@Table(name="USER")
public class UserMW {
...
@Id
@Column(name="id", nullable=false)
@GeneratedValue(strategy=GenerationType.AUTO)
private Long id;
@Column(name="name", nullable=false, length=255)
private String name;
...
}
Получение этого исключения:
java.lang.IllegalArgumentException: An exception occurred while creating a query in EntityManager:
Exception Description: Internal problem encountered while compiling [SELECT post FROM PostMW post LEFT OUTER JOIN LikeMW likes ON post.id = likes.post_id AND likes.user_id =:userID].
Internal Exception: java.lang.NullPointerException
at org.eclipse.persistence.internal.jpa.EntityManagerImpl.createQuery(EntityManagerImpl.java:1605)
at com.jonathan.myworld.model.dao.impl.PostDaoImpl.list(PostDaoImpl.java:72)
at com.jonathan.myworld.service.impl.FeedServiceImpl.getFeed(FeedServiceImpl.java:45)
at com.jonathan.myworld.UserWS.login(UserWS.java:151)
at com.jonathan.myworld.UserWS.loginWithGoogle(UserWS.java:60)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.google.appengine.tools.development.agent.runtime.Runtime.invoke(Runtime.java:130)
at com.google.api.server.spi.SystemService.invokeServiceMethod(SystemService.java:363)
at com.google.api.server.spi.SystemServiceServlet.execute(SystemServiceServlet.java:113)
at com.google.api.server.spi.SystemServiceServlet.doPost(SystemServiceServlet.java:71)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:637)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
at org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1166)
at com.google.appengine.api.socket.dev.DevSocketFilter.doFilter(DevSocketFilter.java:74)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1157)
at com.google.appengine.tools.development.ResponseRewriterFilter.doFilter(ResponseRewriterFilter.java:128)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1157)
at com.google.appengine.tools.development.HeaderVerificationFilter.doFilter(HeaderVerificationFilter.java:34)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1157)
at com.google.appengine.api.blobstore.dev.ServeBlobFilter.doFilter(ServeBlobFilter.java:63)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1157)
at com.google.apphosting.utils.servlet.TransactionCleanupFilter.doFilter(TransactionCleanupFilter.java:50)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1157)
at com.google.appengine.tools.development.StaticFileFilter.doFilter(StaticFileFilter.java:125)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1157)
at com.google.appengine.tools.development.DevAppServerModulesFilter.doDirectRequest(DevAppServerModulesFilter.java:366)
at com.google.appengine.tools.development.DevAppServerModulesFilter.doDirectModuleRequest(DevAppServerModulesFilter.java:349)
at com.google.appengine.tools.development.DevAppServerModulesFilter.doFilter(DevAppServerModulesFilter.java:116)
at org.mortbay.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1157)
at org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:388)
at org.mortbay.jetty.security.SecurityHandler.handle(SecurityHandler.java:216)
at org.mortbay.jetty.servlet.SessionHandler.handle(SessionHandler.java:182)
at org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:765)
at org.mortbay.jetty.webapp.WebAppContext.handle(WebAppContext.java:418)
at com.google.appengine.tools.development.DevAppEngineWebAppContext.handle(DevAppEngineWebAppContext.java:98)
at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
at com.google.appengine.tools.development.JettyContainerService$ApiProxyHandler.handle(JettyContainerService.java:511)
at org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152)
at org.mortbay.jetty.Server.handle(Server.java:326)
at org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542)
at org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:938)
at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:755)
at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218)
at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404)
at org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409)
at org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582)
Caused by: Exception [EclipseLink-0] (Eclipse Persistence Services - 2.5.1.v20130918-f2b9fc5): org.eclipse.persistence.exceptions.JPQLException
Exception Description: Internal problem encountered while compiling [SELECT post FROM PostMW post LEFT OUTER JOIN LikeMW likes ON post.id = likes.post_id AND likes.user_id =:userID].
Internal Exception: java.lang.NullPointerException
at org.eclipse.persistence.internal.jpa.jpql.HermesParser.buildUnexpectedException(HermesParser.java:207)
at org.eclipse.persistence.internal.jpa.jpql.HermesParser.populateQueryImp(HermesParser.java:296)
at org.eclipse.persistence.internal.jpa.jpql.HermesParser.buildQuery(HermesParser.java:163)
at org.eclipse.persistence.internal.jpa.EJBQueryImpl.buildEJBQLDatabaseQuery(EJBQueryImpl.java:142)
at org.eclipse.persistence.internal.jpa.EJBQueryImpl.buildEJBQLDatabaseQuery(EJBQueryImpl.java:116)
at org.eclipse.persistence.internal.jpa.EJBQueryImpl.<init>(EJBQueryImpl.java:102)
at org.eclipse.persistence.internal.jpa.EJBQueryImpl.<init>(EJBQueryImpl.java:86)
at org.eclipse.persistence.internal.jpa.EntityManagerImpl.createQuery(EntityManagerImpl.java:1603)
... 49 more
Caused by: java.lang.NullPointerException
at org.eclipse.persistence.queries.DatabaseQuery.addArgument(DatabaseQuery.java:449)
at org.eclipse.persistence.queries.DatabaseQuery.addArgument(DatabaseQuery.java:419)
at org.eclipse.persistence.internal.jpa.jpql.HermesParser.addArguments(HermesParser.java:98)
at org.eclipse.persistence.internal.jpa.jpql.HermesParser.populateQueryImp(HermesParser.java:287)
Ответ №1:
вы могли бы попытаться извлечь понравившиеся сообщения из списка сообщений, которые вы только что получили ранее. с помощью «SELECT … В» request) и затем заполните логическое значение isLiked; что-то вроде :
...
@Override
public List<PostMW> getFeed(int page, UserMW user) {
List<PostMW> resu<
int offset = page * ConstUtil.FEED_POSTS_PER_PAGE;
postDao.openCurrentSession();
result = postDao.list(offset, ConstUtil.FEED_POSTS_PER_PAGE);
List<Long> postIds = new ArrayList();
for(PostMW post : result){
postIds.add(post.getid();
}
//then EXtract all liked post from list :
Query queryIn = em.createQuery("SELECT p.post.id FROM LikeMW p WHERE p.user = :user AND p.post IN :values");
queryIn.setParameter("values", postIds );
queryIn.setParameter("user", currentUser);
List<Object[]> resultIn = queryIn.getResultList();
Set<Long> postIdLiked ) new HashSet<>();
for(Object[] row: resultIn) {
postIdLiked.add(row[0]);
}
//then fill the boolean isLiked
for(PostMW post : result){
if (postIdLiked.contains(post.getId())
post.setLiked(true);
}
postDao.closeCurrentSession();
return resu<
}
...
Комментарии:
1. Это может быть лучшим ответом, но все же мне пришлось бы выполнить 2 вызова базы данных (я забыл упомянуть, что я вызываю Amazon RDS из GAE, поэтому наименьшее количество вызовов, которые я делаю, будет наилучшим), пройти через 3 цикла, в каждом из которых может быть по 100 элементов, и один «вид цикла» внутри базы данных… Надеюсь, есть способ получше. В любом случае, спасибо за ответ. Если больше никто не ответит, я помечу его как правильное.