java如何在不使用JDBC的情况下从数据库中检索resultset?
我正在编写一个程序,作为一种服务,从电子邮件队列表中提取电子邮件,处理并发送出去。下面是我是如何做到这一点的,它确实工作得很好
MySqlConnect con = new MySqlConnect();
public PreparedStatement preparedStatement = null;
public Connection con1 = con.connect();
//pick up queue and send email
public void email() throws Exception {
try {
while(true) {
String sql = "SELECT id,user,subject,recipient,content FROM emailqueue WHERE status='Pending' ";
PreparedStatement statement = con1.prepareStatement(sql);
ResultSet rs = statement.executeQuery();
while (rs.next()) {
String subject = rs.getString("subject");
String recipient = rs.getString("recipient");
String content = rs.getString("content");
String id = rs.getString("id");
String username = rs.getString("user");
String emailStatus = "DONE";
String errormsg = sendEmail(recipient, subject, content, id,username);
if (!errormsg.equals("")) {
emailStatus = "FAILED";
}
TerminalLogger.printMsg("Status : " + emailStatus);
}
statement.close();
rs.close();
}
} catch(Exception e) {
e.printStackTrace();
TerminalLogger.printMsg("Exception: "+e.toString());
}
con1.close();
Thread.sleep(2000);
}
现在,我很清楚地使用JDBC
来获得循环中的结果集,并如图所示处理它们。当然,我还需要在MySqlConnect.java
属性中指定我的数据库连接。虽然所有这些都可以很好地工作,但我想知道是否有其他方法可以在不使用JDBC的情况下实现相同的目标,即指定连接属性
我在考虑Java持久性。我是新手
编辑
我被告知要使用JPA来实现这一点,我是这样写的:
public void email() throws Exception {
try {
while(true) {
String sql = "select p.id,p.user,p.subject,p.recipient,p.content from Emailqueue p where " +
"status='Pending'";
List<Object[]> list = em.createQuery(sql).getResultList();
for (Object[] obj : list) {
System.out.println(obj[0]);
System.out.println(obj[1]);
System.out.println(obj[2]);
System.out.println(obj[3]);
System.out.println(obj[4]);
}
}
} catch(Exception e) {
e.printStackTrace();
TerminalLogger.printMsg("Exception: " + e.toString());
}
从这里,我将把我想要的参数传递给这个方法。这条路可行吗
编辑2
是否有点不同,如下所示:
String id = ejbCon.getSettingsFacade().getid();
String username = ejbCon.getSettingsFacade().getUser();
String subject = ejbCon.getSettingsFacade().getSubject();
String recipient = ejbCon.getSettingsFacade().getRecipient();
String content = ejbCon.getSettingsFacade().getContent();
String errormsg = sendEmail(recipient, subject, content, id,username);
public String getContent() {
try {
String sql="Select content FROM emailqueue WHERE status='Pending'";
if (em == null) {
throw new Exception("could not found subject");
}
return (String) em.createNativeQuery(sql).getSingleResult();
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
只要稍微了解一下这个方法的样子,其他方法都遵循相同的概念
# 1 楼答案
在使用JPA之前,你必须阅读相关内容WHY JPA
正如在上面的评论中所讨论的,Spring Batch和Spring JPA对于您的用例来说是一个不错的选择, 你可以在网上关注和研究,也可以关注官方文件
Spring JPA tutorial link
Spring Batch tutorial link
愉快学习,希望更多用户在评估他们的优缺点后,能推荐其他好的选项,供您选择并应用到您的用例中
# 2 楼答案