如何在Quartz中使用SQLite？

2 回答

• 2

  问题似乎是sqlite jdbc驱动程序does not support the method ResultSet.getBlob() .

  但是quartz使用此方法来检索分配给Job的JobDataMap .

  如果您仍然希望使用带有sqlite的quartz，您可以扩展StdJDBCDelegate并检索/设置blob，如建议的in this answer .

  乍一看，您似乎只能覆盖这些方法

  • StdJDBCDelegate.getObjectFromBlob（）和

  • StdJDBCDelegate.getJobDataFromBlob（）

  因为我不确定以后会遇到更多问题（例如你可以看到sqlite jdbcdriver有更多unsupported ResultSet methods）我宁愿建议使用一个开箱即用的数据库 .

  回复于 2024-05-03T11:27:52+08:00
• 0

  根据mam10eks的建议，以下代码为我工作 .

  package com.example.quartz.sqlite;   
  
  import org.quartz.impl.jdbcjobstore.StdJDBCDelegate;
  
  import java.io.ByteArrayInputStream;
  import java.io.EOFException;
  import java.io.IOException;
  import java.io.ObjectInputStream;
  import java.sql.ResultSet;
  import java.sql.SQLException;
  
  public class CustomJDBCDelegate extends StdJDBCDelegate {
    @Override
    protected Object getObjectFromBlob(ResultSet rs, String colName) throws ClassNotFoundException, IOException, SQLException {
      byte[] bytes = rs.getBytes(colName);
      Object map = null;
      ByteArrayInputStream bais = null;
      ObjectInputStream ois = null;
      try {
        bais = new ByteArrayInputStream(bytes);
        ois = new ObjectInputStream(bais);
        map = ois.readObject();
      } catch (EOFException ex1) {
        bais.close();
      } catch (IOException e) {
        // Error in de-serialization
        e.printStackTrace();
      }
  
      return map;
    }
  
    @Override
    protected Object getJobDataFromBlob(ResultSet rs, String colName) throws ClassNotFoundException, IOException, SQLException {
      return getObjectFromBlob(rs, colName);
    }
  }
  

  现在将以下内容放在quartz.properties中

  org.quartz.jobStore.driverDelegateClass=com.example.quartz.sqlite.CustomJDBCDelegate
  

  回复于 2024-05-03T11:27:52+08:00