1

代码有什么问题。请帮助我。如何将查询数组传递给函数 exeSearchQuery();

  public class  MyDBConnect
    {
    Connection dbCon = null;
        public String DB_USERNAME = "root";
        public String DB_PASSWORD = "root";
        private String DB_DRIVER_CLASS = "com.mysql.jdbc.Driver";
        private String DB_URL = "jdbc:mysql://localhost/yatin";
    public  boolean connectToDb( ) throws Exception{
        try{
    Class.forName (DB_DRIVER_CLASS);
            dbCon = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD);
            //dbCon = DriverManager.getConnection(tns, DB_USERNAME, DB_PASSWORD);
            return true;
        }catch(Exception e){
            System.out.println("Error in DBConnect "+e);
            return false;
        }
    }

    public ArrayList exeSearchQuery(String sql[]) throws Exception{

        Statement stmt = null;
        ResultSet rs = null;
        ArrayList  data = null;
        int recordSize=0;
            try{

                connectToDb( );
                stmt = dbCon.createStatement( );
                rs = stmt.executeQuery(sql);
                ResultSetMetaData rsmd = rs.getMetaData();
                int numOfCols = rsmd.getColumnCount();

                data = new ArrayList( );
                String q="";
                for(int k=0;k<2;k++)
                {
                    boolean chkQuery=true;
                    q=sql[k];
                    while(rs.next()){
                    chkQuery=true;
                    recordSize=recordSize+1;
                    String row[] = new String[numOfCols];
                    for(int col=1;col<=numOfCols ;col++)
                    {
                        row[col-1] = rs.getString(col);
                    }
                    data.add(row);
                    }
                    System.out.println("data="+data);

                    if(chkQuery=true)
                        {
                        break;
                        }
                        else
                        {
                            q=sql[1];
                            while(rs.next())
                            {
                                chkQuery=true;
                                recordSize=recordSize+1;
                                String row[] = new String[numOfCols];
                                for(int col=1;col<=numOfCols ;col++)
                                {
                                    row[col-1] = rs.getString(col);
                                }
                                data.add(row);
                                System.out.println("data="+data);
                            }
                        }
                        if(chkQuery=true)
                        {
                        break;
                        }
                    }

            }catch(Exception e){
                System.out.println("Error in DBConnect "+e);
            }finally{
                if(rs !=null) rs.close();
                if(stmt !=null)stmt.close();
                if(dbCon !=null) dbCon.close();
            }
        return data;
        //return recordSize;
    }

        public static void main(String a[]) throws Exception{
            MyDBConnect db = new MyDBConnect( );
            //db.connectToDb();
                            System.out.println("Connected");
            String query[] ={"select a.ID,a.VDT,a.AID,a.NAME,a.ADD,a.CONTACT,a.PTM,a.DEPT_TEXT,a.FLOOR,b.LINK from tm_co123 a LEFT JOIN tm_co456 b ON a.ID=b.PID where a.NAME like 'anil' ORDER BY ID","select a.ID,a.VDT,a.AID,a.NAME,a.ADD,a.CONTACT,a.PTM,a.DEPT_TEXT,b.LINK from tm_co123 a LEFT JOIN tm_co456 b ON a.ID=b.PID where a.ADD like 'anil' ORDER BY ID"};       
            db.exeSearchQuery(query[]);
        }
    }

如果我运行上面的代码，我会收到错误

MyDBConnect.java:473: '.class' expected
                db.exeSearchQuery(query[]);
                                         ^
1 error

如果我用 query 替换 query[] 那么它会给我错误

MyDBConnect.java:406: executeQuery(java.lang.String) in java.sql.Statement canno
t be applied to (java.lang.String[])
                        rs = stmt.executeQuery(sql);
                                 ^
Note: MyDBConnect.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 error
4

6 回答 6

2

您不能传递 a String[]to executeQuery，它需要一个单一String的参数。要么分别执行每个查询，要么使用也许将它们变成一个UNION。

于 2012-08-22T09:57:00.067 回答
1

您不能将数组传递给executeQuery();方法，只有您可以传递字符串，例如-executeQuery(sql[0]);

于 2012-08-22T10:01:11.843 回答
1

即使你的代码不是你能做的最好的，你的sql也是一个数组而不是一个String. 并且数组不能传递给executeQuery.

这是您的方法的快速编辑：

        ...
            connectToDb( );
            for(String str : sql){ //This way you're doing each query of your array
                stmt = dbCon.createStatement( );
                rs = stmt.executeQuery(str);
                ResultSetMetaData rsmd = rs.getMetaData();
                int numOfCols = rsmd.getColumnCount();
                data = new ArrayList( );
                String q="";
                for(int k=0;k<2;k++){
                    boolean chkQuery=true;
                    q=sql[k];
                    while(rs.next()){
                        chkQuery=true;
                        recordSize=recordSize+1;
                        String row[] = new String[numOfCols];
                        for(int col=1;col<=numOfCols ;col++){
                            row[col-1] = rs.getString(col);
                        }
                    data.add(row);
                }
            }
        ...
于 2012-08-22T10:02:37.813 回答
1

stmt.executeQuery()方法只接受String参数。

  1. 在您的 main() 调用db.exeSearchQuery()方法中，它接受参数String[]。但是对于写 like exeSearchQuery(query[])，query已经是一维数组了。这是第一个错误。

  2. 在您的exeSearchQuery(String sql[])方法中， stmt.executeQuery()需要String参数。像这样写stmt.executeQuery(sql)。由于现在sql是一维数组。这是第二个错误。

我尝试这样，在 exeSearchQuery(String sql[]) 方法中

Edit rs = stmt.executeQuery(sql[0]);

在 main() 方法中，

String[] query = {.........};
db.exeSearchQuery(query);// edited

它连接到数据库。

于 2012-08-22T10:03:11.463 回答
0

我executeSearchQuery(query)按照我的定义通过了它String query[]={} ，它起作用了，我得到了想要的结果。

于 2012-08-30T05:09:20.140 回答
0

executeQuery接受 String不要String[]做类似下面的事情。

List<ResultSet> lList=new ArrayList<ResultSet>();
for(String query :sql){
            ResultSet rs = stmt.executeQuery(query);
            lList.add(rs);
        }
于 2012-08-22T10:07:23.133 回答