java - Android JDBC MySQL 通过数据库获取表

Question

我学习了一些教程，但它们都非常简单，无法在我的解决方案中使用。

我通过 JDBC MySQL 连接到数据库。

public class ConnCore extends AsyncTask<Void, Void, Boolean> {

Activity activity;
    Context context;
    public ConnCore(Context context, Activity currActivity) {
        this.context = context.getApplicationContext();
        this.activity = currActivity;
    }


    @Override
    protected Boolean doInBackground(Void... params) {


        try{Class.forName("com.mysql.jdbc.Driver");}
        catch(Exception e){
           DataStore.DataStoreClass.connExc = e;
            return false;}


        try{

          DataStore.DataStoreClass.mysqlConn = DriverManager.getConnection(DataStore.DataStoreClass.connectionString);

            return true;
        }catch(Exception e){
            DataStore.DataStoreClass.connExc = e;
            return false;
        }





    }

    @Override
    protected void onPostExecute (Boolean b) {


         if(b == true) {

            Intent intent = new Intent(context, DBList.class);
            intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
            context.startActivity(intent);



        } else {
            AlertDialog alertDialog = new AlertDialog.Builder(activity).create();
            alertDialog.setTitle("Error");
            alertDialog.setMessage(DataStore.DataStoreClass.connExc.toString());
            alertDialog.show();

        }
}

这将与这个字符串相关联:

static String connectionString = "jdbc:mysql://XXX.XXX.XXX.XXX:3306?user=root&password=test&autoReconnect=true&failOverReadOnly=false&maxReconnects=10";

如果连接成功，它会启动新的 Activity DBList，它会启动新的 AsyncTask 来获取数据库。AsyncTask 看起来像这样:

public class GetDBList extends AsyncTask<Void, Void, Boolean> {
    Activity activity;
    Context context;
    public GetDBList(Context context, Activity activity){
        this.activity = activity;
        this.context = context;
    }

    @Override
    protected Boolean doInBackground(Void... params){


        Statement stmt = null;
        String query = "SHOW DATABASES";
        DataStore.DataStoreClass.DBResponse = new ArrayList<String>();



        try {
            DatabaseMetaData meta = DataStore.DataStoreClass.mysqlConn.getMetaData();
            ResultSet res = meta.getCatalogs();
            while (res.next()) {
                DataStore.DataStoreClass.DBResponse.add(res.getString("TABLE_CAT"));

            }
            res.close();
            return true;
        }
        catch (SQLException e){

            AlertDialog alertDialog = new AlertDialog.Builder(activity).create();
            alertDialog.setTitle("Error");
            alertDialog.setMessage(e.toString());
            alertDialog.show();
            return false;
        }





    }

    @Override
    protected void onPostExecute(Boolean b){
       if(b) {
           ArrayAdapter<String> arrayAdapter = new ArrayAdapter<String>(context, android.R.layout.simple_list_item_1, DataStore.DataStoreClass.DBResponse){
               @Override
               public View getView(int position, View convertView, ViewGroup parent) {
                   View view = super.getView(position, convertView, parent);
                   TextView text = (TextView) view.findViewById(android.R.id.text1);
                   text.setTextColor(Color.BLACK);
                   return view;
               }
           };
           ListView lv = (ListView) activity.findViewById(R.id.db_lv);
           lv.setAdapter(arrayAdapter);

           lv.setOnItemClickListener(new AdapterView.OnItemClickListener() {
               public void onItemClick(AdapterView<?> parent, View view,
                                       int position, long id) {


                   DataStore.DataStoreClass.currentDB = ((TextView) view).getText().toString();
                   Toast.makeText(context, DataStore.DataStoreClass.currentDB,
                           Toast.LENGTH_SHORT).show();

                   AlertDialog alertDialog = new AlertDialog.Builder(activity).create();
                   alertDialog.setTitle("Error");
                   alertDialog.setMessage(DataStore.DataStoreClass.connExc.toString());
                   alertDialog.show();

               }
           });

       }


    }
}

到目前为止，一切正常，我可以获取带有数据库的 ListView。

现在。每个 List_Item 都有 onClickListener。如何将字符串值(包含数据库名称)传递到现有连接以获取其表？

每个教程都已经带有数据库名称。我正在尝试创建一个通用数据库客户端，因此您实际上不知道服务器上有哪些数据库。

String url = "jdbc:mysql://" + serverName +  "/" + schema;

而且我不想关闭以前的连接并直接与数据库建立一个新连接

那么有没有可能“编辑”

(static Connection mysqlConn;)
DataStore.DataStoreClass.mysqlConn = DriverManager.getConnection(DataStore.DataStoreClass.connectionString);

不知何故......或任何其他方式？

谢谢。

Answer 1

如果我没有理解你的意思，你想连接到数据库，但是你事先并不知道数据库名称。正确的？

如果以上为真，那么您无需提供数据库名称即可连接到数据库。只需向 DriverManager 提供主机名和端口，如下所示:

String url="jdbc:mysql://{hostname}:{port}"
Connection conn = DriverManager.getConnection(url, username, password);

现在您有了一个有效的连接，您需要找出那里有哪些数据库。你已经知道了，但是，无论如何我都会提供一个例子，这样我就涵盖了所有内容。使用上面的 java.sql.Connection 对象创建一个 java.sql.Statement，如下所示:

Statement stmt = conn.createStatement();
String SQL = "SHOW DATABASES";

运行上面的SQL语句得到数据库名称列表如下:

ResultSet rs = stmt.executeQuery(SQL);

遍历返回的数据库名称列表，并将重要的添加到列表中，跳过系统和其他内部数据库。见下文:

List<String> dbNames = new ArrayList<String>(); 

while (rs.next()) {
    // Retrieve by column name
    String name = rs.getString("Database");
    if(!name.equals("information_schema") && !name.equals("mysql") && !name.equals("performance_schema") && !name.equals("sys")) {
        dbNames.add(name); 
    }
}

假设我的数据库中只有db1、db2和db3，那么打印时列表将包含以下内容

[db1, db2, db3]

现在我想检索上述每个数据库的表列表。我在db1数据库中手动创建了表t1和t2，在db2数据库中创建了x1和x2数据库，在db3数据库中创建了z1和z2数据库，看看我是怎么做的迭代器以以下不同方式遍历数据库表:

方法 1:您可以使用 setCatalog(String dbname) java.sql.Connection 类的方法，以便将数据库名称设置为 Connection 对象。这类似于 USE {dbname} sql 命令。看下面的例子

for(int i = 0; i < dbNames.size(); i++) {
    //here I am setting the dbname in connection obj
    conn.setCatalog(dbNames.get(i));
    //then I am creating a new Statement
    stmt = conn.createStatement();

    sql = "SHOW TABLES";
    rs = stmt.executeQuery(sql);
    while(rs.next()) {
        System.out.println(rs.getString(1) 
           + " is a table in " + dbNames.get(i) + " database.");
    }
}

方法 2: 在这种方法中，您可以通过更改 java.sql.Connection 类的 setCatalog(String dbname) 方法来避免使用SQL命令如下:

sql = "SHOW TABLES FROM " + dbNames.get(i);

这两种方法都应该为您提供相同的输出，如下所示:

[db1, db2, db3]
t1 is a table in db1 database.
t2 is a table in db1 database.
x1 is a table in db2 database.
x2 is a table in db2 database.
z1 is a table in db3 database.
z2 is a table in db3 database.