Nem értem miért rossz a következő mysql lekérdezésem. NullPointer Exception a jutalmam.
package main;
import java.sql.ResultSet;
import java.sql.SQLException;
import query.Query;
public class Main {
public static void main(String[] args) throws SQLException {
Query query = new Query();
ResultSet res = query.getAllCountries();
while (res.next()) {
int cid = res.getInt("country_id");
String name = res.getString("name");
System.out.println(cid + "\t" + name);
}
}
}
package query;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import dbcfg.DbCfg;
public class Query {
private Connection connection;
public void connect() throws ClassNotFoundException, SQLException {
Class.forName(DbCfg.DRIVER);
Connection connection = DriverManager.getConnection(DbCfg.URL
+ DbCfg.DB_NAME, DbCfg.USER, DbCfg.PASSWORD);
}
public ResultSet getAllCountries() throws SQLException {
Statement s = connection.createStatement();
return s.executeQuery("Select country_id from countries");
}
}
package dbcfg;
public class DbCfg {
public static final String URL = "jdbc:mysql://192.168.1.80:3306/";
public static final String DB_NAME = "country";
public static final String DRIVER = "com.mysql.jdbc.Driver";
public static final String USER = "java";
public static final String PASSWORD = "java";
}