Объявление анонимного внутреннего класса Java - PullRequest
Новая
       11

Объявление анонимного внутреннего класса Java

0 голосов
/ 10 января 2019

Как определить анонимный внутренний класс отдельно от блока конструктора?

Например, в моих кодах я хочу, чтобы method2 делал то же самое, что и method1. Единственное отличие состоит в том, что method2 использует класс Factory для создания ClosableResultSet. 

import java.sql.*;

public class Demo {

    public static void main(String[] args) {
        method1();
        method2();  
    }

    static void method1() {

        Connection conn;
        try {
            conn = DriverManager.getConnection("jdbc:h2:C:/myDB", "sa", "sa");

            String sql = "select * from Customers";

            try (ClosableResultSet rs = new ClosableResultSet(conn, sql) {
                @Override
                public void handleError(SQLException e, String action) {
                    System.out.print(action + ": " + e.getMessage());       
                }               
            }) {
                while (rs.next()) {
                    System.out.print("Name: " + rs.getString("name") + "\n");
                }
            }

        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }               

    }


    static void method2() {

        String sql = "select * from Customers";

        //here has the syntax errors    
        try (ClosableResultSet rs = Factory.createResultSet(sql) {
            @Override
            public void handleError(SQLException e, String action) {
                System.out.print(action + ": " + e.getMessage());           
            }               
        }) {
            while (rs.next()) {
                System.out.print("Name: " + rs.getString("name") + "\n");
            }


        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }           

    }   
}



import java.sql.*;

public class Factory {
    public static ClosableResultSet createResultSet(String sql) throws SQLException {
        Connection conn = DriverManager.getConnection("jdbc:h2:C:/myDB", "sa", "sa");

        return new ClosableResultSet(conn, sql);
    }
}


import java.sql.*;

public class ClosableResultSet implements java.io.Closeable {

    private ResultSet rs;

    public ClosableResultSet(Connection conn, String sql) throws SQLException  {
        Statement stmt = conn.createStatement();
        rs = stmt.executeQuery(sql);    
    }

    public Boolean next() {
        try {
            return rs.next();
        } catch (SQLException e) {
            handleError(e, "next");
            return false;
        }
    }

    public String getString(String columnLabel) {
        try {
            return rs.getString(columnLabel);
        } catch (SQLException e) {
            handleError(e, "get " + columnLabel);
            return "";
        }
    }


    @Override
    public void close() {       
        try {
            rs.close();
        } catch (SQLException e) {
            handleError(e, "close");
        }

    }

    public void handleError(SQLException e, String action) {
        // to be override   
    }

}

Я не хочу объявлять анонимный внутренний класс в классе Factory, есть ли какое-нибудь лямбда-выражение, позволяющее мне поместить его в method2?

Ответы [ 2 ]

0 голосов
/ 10 января 2019

Вы можете создать другой метод Factory, который принимает BiConsumer в дополнение к String sql. Примерно так: 

import java.sql.*;
import java.util.function.BiConsumer;

public class Factory {

    public static ClosableResultSet createResultSet(String sql) throws SQLException {
        Connection conn = DriverManager.getConnection("jdbc:h2:C:/myDB", "sa", "sa");

        return new ClosableResultSet(conn, sql);
    }

    public static ClosableResultSet createResultSet(String sql, BiConsumer<SQLException, String> handler) throws SQLException {
        Connection conn = DriverManager.getConnection("jdbc:h2:C:/myDB", "sa", "sa");

        return new ClosableResultSet(conn, sql) {
            @Override
            public void handleError(SQLException e, String action) {
                handler.accept(e, action);
            }
        };
    }
}

И тогда ваш method2 должен быть: 

static void method2() {

    String sql = "select * from Customers";

    try (ClosableResultSet rs = Factory.createResultSet(
            sql,
            (e, action) -> System.out.print(action + ": " + e.getMessage())
    )) {
        while (rs.next()) {
            System.out.print("Name: " + rs.getString("name") + "\n");
        }

    } catch (SQLException e) {
        e.printStackTrace();
    }

}
0 голосов
/ 10 января 2019

Да, вы можете сделать что-то вроде этого: 

import java.sql.*;

public class Demo {

    public static void main(String[] args) {
        method1();
        method2();  
    }

    static void method1() {

        Connection conn;
        try {
            conn = DriverManager.getConnection("jdbc:h2:C:/myDB", "sa", "sa");

            String sql = "select * from Customers";

            try (ClosableResultSet rs = new ClosableResultSet(conn, sql) {
                @Override
                public void handleError(SQLException e, String action) {
                    System.out.print(action + ": " + e.getMessage());       
                }               
            }) {
                while (rs.next()) {
                    System.out.print("Name: " + rs.getString("name") + "\n");
                }
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }               
    }

    static void method2() {

        String sql = "select * from Customers";

        //here has the syntax errors
        try (ClosableResultSet rs = Factory.createResultSet(
                sql, (e, action) -> System.out.print(action + ": " + e.getMessage())
        )) {
            while (rs.next()) {
                System.out.print("Name: " + rs.getString("name") + "\n");
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

...

import java.sql.*;

public class Factory {
        public static ClosableResultSet createResultSet(String sql, final ErrorHandller errorHandller) throws SQLException {
        Connection conn = DriverManager.getConnection("jdbc:h2:C:/myDB", "sa", "sa");

        return new ClosableResultSet(conn, sql) {
            @Override
            public void handleError(SQLException e, String action) {
                errorHandller.handleError(e, action);
            }
        };
    }

    interface ErrorHandller {
        void handleError(SQLException e, String action);
    }
}

...

Как видите, добавлен новый интерфейс ErrorHandller. Также Factory::createResultSet теперь получает экземпляр ErrorHandller в качестве второго аргумента. И затем в Demo::method2 мы передаем лямбду как второй аргумент метода Factory.createResultSet.

...