1
22
23 package com.liferay.portal.service.impl;
24
25 import com.liferay.portal.SystemException;
26 import com.liferay.portal.kernel.dao.db.DB;
27 import com.liferay.portal.kernel.dao.db.DBFactoryUtil;
28 import com.liferay.portal.kernel.dao.jdbc.DataAccess;
29 import com.liferay.portal.kernel.log.Log;
30 import com.liferay.portal.kernel.log.LogFactoryUtil;
31 import com.liferay.portal.service.base.QuartzLocalServiceBaseImpl;
32
33 import java.sql.Connection;
34 import java.sql.PreparedStatement;
35 import java.sql.ResultSet;
36
37
42 public class QuartzLocalServiceImpl extends QuartzLocalServiceBaseImpl {
43
44 public void checkQuartzTables() throws SystemException {
45 Connection con = null;
46 PreparedStatement ps = null;
47 ResultSet rs = null;
48
49 try {
50 con = DataAccess.getConnection();
51
52 ps = con.prepareStatement(
53 "select count(*) from QUARTZ_JOB_DETAILS");
54
55 rs = ps.executeQuery();
56
57 if (rs.next()) {
58 return;
59 }
60 }
61 catch (Exception e) {
62 if (_log.isWarnEnabled()) {
63 _log.warn(e.getMessage());
64 }
65 }
66 finally {
67 DataAccess.cleanUp(con, ps, rs);
68 }
69
70 DB db = DBFactoryUtil.getDB();
71
72 try {
73 db.runSQLTemplate("quartz-tables.sql", false);
74 }
75 catch (Exception e) {
76 throw new SystemException(e);
77 }
78 }
79
80 private static Log _log =
81 LogFactoryUtil.getLog(QuartzLocalServiceImpl.class);
82
83 }