如何从数据库连接类中调用方法

Question

最近我正在制作一个小系统，其中我使用Ms Access作为数据库，分为以下三个包：

1)Classes----> 基于面向对象编程(OOP)的概念

2)GUI------> Jform + .java文件

3)Images----> 一些我自己做的图标

在Classes包中，我创建了一个DBConnection类（使用UCanAccess）。

import java.sql.*;
public class DBConnection {
public DBConnection() {

    try {
        String driver = "net.ucanaccess.jdbc.UcanaccessDriver";
        Class.forName(driver);
        String dbPath = "jdbc:ucanaccess://E:\\University Docs\\BSCS 3A\\Object Oriented Programming\\LibraryManagementSystem\\LMSDatabase.accdb";
        Connection con = DriverManager.getConnection(dbPath);
        Statement st = con.createStatement();
        System.out.println("Connection Succesful");
        ResultSet rsObject = st.executeQuery(dbPath);
        con.close();
    } catch (Exception sqlEx) {
        System.out.println(sqlEx);
}
}                    }

接下来我创建了一个 Loger 类，在同一包中创建登录和注销方法。问题是如何使用 DBConnection 类在这个类中执行我的查询？下面是 Loger 类的代码：

public class Loger { 

private String lname, lpassword;

public Loger(String lname, String lpassword) {
    this.lname = lname;
    this.lpassword = lpassword;
    //Login();
}


public String Login()throws ClassNotFoundException,SQLException
{
    DBConnection d1 = new DBConnection();
    String query1 = "SELECT * FROM Admintable WHERE Admin_ID = ' "+this.lname+" AND Admin_Password = '"+this.lpassword+"'" ;

    return "Success!";

}                   }

总之，我卡住了，请帮忙，因为我必须创建更多的类（基于OOP），并在这些类中仅编写方法以执行不同的查询。

- Zujaj Misbah Khan

---

你在面对面向对象编程方面遇到了问题。为什么会标记“NetBeans”？ - Minar Mahmud

Answer 1

你需要mysql-connector-java API，可以通过项目属性 -> 库 -> 添加 jar 来导入到你的项目中。

请按照以下示例代码操作：

public class Database {
    Connection conObj;
    Statement stObj;

    public Database() throws SQLException , ClassNotFoundException {
        Class.forName("com.mysql.jdbc.Driver"); /*Loading Driver class for JDBC*/

 conObj = DriverManager.getConnection("jdbc:mysql://localhost:3306/mytestdb","root",""); /*Creating Connection class's Object which consist of database url , username and password*/

stObj = conObj.createStatement();/*Creating Statement Class's object which is responsible for performing all db tasks*/
    }

    public void fetchData() throws Exception
    {
        String query = "select * from user";
        ResultSet rs = stObj.executeQuery(query);

        while(rs.next())
        {
            System.out.println("Name : "+rs.getString("name"));
            System.out.println("age : "+rs.getInt("age"));
        }
    }

    public void insertData(String name, int age) throws SQLException 
    {
        if(name!=null && age!=0)
        {
            String query = "insert into user values(\""+name+"\","+age+")";
            int a = stObj.executeUpdate(query);

            if(a == 1)
            {
                System.out.println("Update Successful");
            }
            else
            {
                System.out.println("Update Failed");
            }
        }
    }

    void deleteData() {
    }

    void deleteData(String name) throws Exception 
    {
        String query = "delete from user where name = \""+name+"\"";
        int a = stObj.executeUpdate(query);

        if(a == 1)
        {
                System.out.println("delete Successful");
        }
        else
        {
                System.out.println("deletion Failed");
        }
    }
}

public class main {

    public static Database d;
    public static Scanner sc;

    static 
    {
        try{
            sc = new Scanner(System.in); 
            d = new Database();
        }
        catch(Exception e)
        {
            throw new RuntimeException(e);
        }
    }

  public static void main(String... q)
  {
      main mn = new main();
      try{
          System.out.println("Enter your option");
          System.out.println("1) fetch data");
          System.out.println("2) insert data");
          System.out.println("3) delete data");
          System.out.println("\n /////////////////////////// \n");
          int a = sc.nextInt();
          switch(a)
          {
              case 1 :
                  mn.fetchData();
                  break;
              case 2 :
                  mn.takeDetails();
                  break;
              case 3 :
                  mn.deleteData();
                  break;
              default:
                  System.out.println("Try Again");
                  break;
          }
      }
      catch(Exception e)
      {
          e.printStackTrace();
      }
  }

  public void takeDetails() throws Exception
  {
     System.out.println("Enter name");
     String name = sc.next();
     System.out.println("Enter age");
     int age = sc.nextInt();
     d.insertData(name, age);
  }

  public void fetchData() throws Exception
  {
      d.fetchData();
  }

  private void deleteData() throws Exception {
        System.out.println("Enter name of the user whose record is to be deleted");
        String name = sc.next();
        d.deleteData(name);
    }
}

阅读中间的注释以获得解释。要查看完整的教程，请关注链接。 希望这可以帮到你。

- codechefvaibhavkashyap

---

非常感谢您，但我不熟悉API术语。另外一件事是，Netbeans 8.0不再支持JDBC。 - Zujaj Misbah Khan

APIs是jar文件，即您需要的额外类。在您的情况下，它是mysql驱动器。 此外，上面的代码仅在netbeans 8上开发，JDBC是一个概念，因此它没有关于支持的问题，或者我无法理解您的问题。 - codechefvaibhavkashyap

@ZMKhan 你错了。NetBeans 没有选择，必须支持 JDBC。它是 Java 语言的一部分。 - user207421

@EJP 也许你是对的，但我使用 UcanAccessDriver，因为我知道 Oracle 已经移除了 ODBC 桥接连接。 - Zujaj Misbah Khan

Answer 2

你设计类的方式，可以这样做： 从 DBconnection() 中省略这两行代码以使用连接：

ResultSet rsObject = st.executeQuery(dbPath);
con.close();

将st、conn等成员变量设为DBConnection的成员变量，这样你就可以在类外面使用它们。

在Logger类中执行以下操作：

public String Login()throws ClassNotFoundException,SQLException
{
    try {
        DBConnection d1 = new DBConnection();
        String query1 = "SELECT * FROM Admintable WHERE Admin_ID = ' "+this.lname+" AND Admin_Password = '"+this.lpassword+"'" ;
        Resultset rs = d1.st.executeQuery(query1);  // assuming st is "default". 
                                                    // or u can make st private and use a get method (better) 
        // Check login, set to a "stringObject" //declare outside the scope of try-catch        
    } catch(Exception ex) {
        //
    }
    return stringObject; 
}   

但是我会以稍微不同的方式设计类。我会在DBConnection中创建一个登录方法，例如：

public boolean login(String id, String pass) {
    boolean loggedin = false;
    try {
        // Connect to db
        // execute SQL
        // modify loggedin if necessary
    } catch (...) {
    } finally {
        try {
            // close connections
        } catch(...) {
        }
    }
    return loggedin;
}

然后在Logger的login()中：

DBConnection d1 = new DBConnection(); // no connections in constructor
boolean logged = d1.login(this.lname, this.lpassword);

- Minar Mahmud

---

因为你的拼写错误以及你建议该语句应该是类的成员，这两者都不合适。 - user207421

不知道这里不能使用缩写。 而我在答案的第一部分提出的建议是根据他的设计方式。然而，我认为第二部分没有任何问题。而且我认为我用标题清楚地将这两个部分分开了。 - Minar Mahmud