JDBC simple framework

import utils.JdbcUtil;
import utils.annotations.Aggregated;
import utils.annotations.SqlSupport;

@SqlSupport(PASSWORD = "123456")
public class Main {
    public static void main(String[] args) {
        JdbcUtil.connectByConfig(Main.class);
        //...
    }
}

public interface MY {
    // 一些接口方法示例
    @Aggregated(sql = "select count(id) from city")
    int count();

    @Aggregated(sql = """
           select
           (
               (select city_id from undertake
               where record_id = (select id from record where item_name = ?) and type = ?)
               =
               (select city_id from staff where name = ?)
           );
          """)
    boolean checkCourier(String itemName,int type,String name);
    
    @Update(sql = "insert into record(item_name, item_class, item_price, state, company_id) values (?,?,?,?,?)")
    boolean addRecord(String item_name,String item_class,double item_price,int state,int company_id);

    @Update(sql = "update record set state = ? where item_name = ?")
    boolean updateRecord(Integer state,String item_name);
};

//main 方法中使用
static MY mapper = JdbcUtil.getMapper(Main.class,MY.class);

public static void main(String[] args) {
    JdbcUtil.connectByConfig(Main.class);
    System.out.println(mapper.count());
}

@Aggregated(sql = """
            select s.name,c.name ,s.state from ship s
            join company c on s.company_id = c.id
            where s.name = ?
            """)
    public ShipInfo getShipInfo(LogInfo log, String name) {
            try {
                return SqlFactory.query(
                        this.getClass().getMethod("getShipInfo", LogInfo.class, String.class),
                        r -> new ShipInfo(r.getString(1),
                                r.getString(2),
                                r.getInt(3) == 1),
                        name
                );
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        } 
    }

// 返回多行后求平均值
@Multiple(sql = """
          select u.tax , r.item_price from undertake u
          join record r on u.record_id = r.id
          where u.type = ? and r.item_class = ? and u.city_id =
          (select c.id from city c where c.name = ?)
          """)
  public double getTaxRate(String city, String itemClass, int type,String format) {
      try {
          return SqlFactory.query(
                  this.getClass().getMethod("getTaxRate", String.class, String.class, int.class,String.class),
                  r -> r.getDouble(1) / r.getLong(2),
                  res -> Double.parseDouble(String.format(format, res.stream()
                          .collect(Collectors.summarizingDouble(Double::doubleValue))
                          .getAverage())),
                  type, itemClass, city);
      } catch (Exception e) {
          e.printStackTrace();
          return -1;
      }
  }

private int handleCount(String type) {
        String sql = String.format("select count(id) from %s where trim(name) != '' ", type);
        try {
            return SqlFactory.handleSingleResult(
                    SqlFactory.handleQuery(sql, (Object) null),
                    r -> r.getInt(1)
            );
        } catch (Exception e) {
            e.printStackTrace();
            return -1;
        }
    }