读取mysql中数据的问题

zhangv

为什么得到的结果（ResultSet）好像是空的一样。什么都取不出来，而同样的sql在mysql中验证是正确的。

似乎Statement的executeQuery和executeUpdate并没有执行。不知为什么。

注：同样的过程用access测试也通过了，可就是mysql？？？是不是有特殊的用法？
郁闷，帮帮小弟。。。。

吴奇

"得到的结果（ResultSet）好像是空的一样"????????

你先确定是不是空，不然可以举出一大堆可能

rs = statement.executeQuery(sql);
return rs.next();

zhangv

弄错了

不是空的，但是里面的东西都不对。具体情形如下：
数据库中：                        取出：
   整数                  以p开始的字母（0--p,1--q,2--r,....)
字符（英文字母）    空白
汉字                       乱麻

badseed

不知你用的是什么连接，是JDBC还是ODBC桥阿
贴出代码看一看
不明白  》》 整数 以p开始的字母（0--p,1--q,2--r,....)
整数怎么会有字母？

zhangv

我用的是mysql带的包

那个没说清楚，这样：
如果字段值是“0”，取出来的就成了"p"，
同样“1”成了“q"以次类推。

zhangv

cinc斑竹帮帮我

badseed

贴代码出来看一下，再把表的字段数据类型说一下

zhangv

作的是一个封装数据库操作的类，在access测试全部通过，即使是mysql也好像只是编码的问题，因为生成表的操作也是可以成功的。

1. 
   
2. import java.sql.*;
   
3. import java.io.*;
   
4. 
   
5. public class DB {
   
6.     private Connection connection = null;
   
7.     private Statement statement = null;
   
8.     private ResultSet resultset=null;
   
9. 
   
10. 
    
11.     public DB(String DBType, String user, String password, String DBName) {
    
12.         try {
    
13.             connection = InitDB(DBType, user, password, DBName);
    
14.             statement = connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
    
15.         } catch (Exception e) {
    
16.             e.printStackTrace();
    
17.         }
    
18.     }
    
19. 
    
20. 
    
21.     private Connection InitDB(String DBType, String user, String password, String DBName)
    
22.             throws ClassNotFoundException, SQLException {
    
23.       
    
24.         Connection c = null;
    
25.         String DBUrl = null;
    
26.         if (DBType == "access") {
    
27.             Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
    
28.             DBUrl = "jdbc:odbc:" + DBName;
    
29.             c = DriverManager.getConnection(DBUrl);
    
30.         }
    
31.         if (DBType == "mysql") {
    
32.             try {
    
33.                 Class.forName("org.gjt.mm.mysql.Driver");         
    
34.             } catch (Exception e) {
    
35.                 e.printStackTrace();
    
36.             }
    
37.             DBUrl = "jdbc:mysql://localhost/" + DBName;
    
38.             c = DriverManager.getConnection(DBUrl, user, password);
    
39.         }
    
40.         return c;
    
41.     }
    
42. 
    
43. 
    
44.     public int getTableCount(String tablename) {
    
45.         String sql = "select count(*) from " + tablename;
    
46.         int total = 0;
    
47.         try {
    
48.             resultset = statement.executeQuery(sql);
    
49.             resultset.next();
    
50.             total = resultset.getInt(1);
    
51.             System.out.println("total:" + total);
    
52.         } catch (SQLException sqle) {
    
53.             sqle.printStackTrace();
    
54.         }
    
55.         return total;
    
56.     }
    
57. 
    
58. 
    
59.     public boolean deleteTable(String tablename) {
    
60.         boolean success = false;
    
61.         String sql = "drop table " + tablename;
    
62.         try {
    
63.             statement.execute(sql);
    
64.             success = true;
    
65.         } catch (SQLException sqle) {
    
66.             sqle.printStackTrace();
    
67.         }
    
68.         return success;
    
69.     }
    
70. 
    
71. 
    
72.     public boolean createTable(String sql) {
    
73.         boolean success = false;
    
74.         try {
    
75.             success = statement.execute(sql);
    
76.         } catch (SQLException sqle) {
    
77.             sqle.printStackTrace();
    
78.         }
    
79.         return success;
    
80.     }
    
81. 
    
82. 
    
83.     public void release() {  
    
84.         try {
    
85.             statement.close();
    
86.             connection.close();
    
87.             resultset.close();
    
88.         } catch (SQLException sqle) {
    
89.             sqle.printStackTrace();
    
90.         }
    
91.     }
    
92. 
    
93. 
    
94.     public ResultSet executeQuery(String sql) {
    
95. 
    
96.         try {
    
97.             resultset = statement.executeQuery(sql);
    
98.         } catch (SQLException sqle) {
    
99.             sqle.printStackTrace();
    
100.         }
     
101.         return resultset;
     
102.     }
     
103. 
     
104. 
     
105.     public void executeUpdate(String sql) {
     
106.         try {
     
107.             statement.executeUpdate(sql);
     
108.         } catch (SQLException sqle) {
     
109.             sqle.printStackTrace();
     
110.         }
     
111.     }
     
112. 
     
113. 
     
114.     public ResultSet getTables() {
     
115.         ResultSet r = null;
     
116.         try {
     
117.             DatabaseMetaData dmd = connection.getMetaData();
     
118.             r = dmd.getTables(null, null, null, null);
     
119.         } catch (SQLException sqle) {
     
120.             sqle.printStackTrace();
     
121.         }
     
122.         return r;
     
123.     }
     
124. 
     
125. 
     
126.     public void temp() {
     
127.         ResultSet r = null;
     
128.         try {
     
129.             //statement.execute("select * from list order by id");
     
130.             //statement.execute(" insert into list values('9','222','333','444','555','666','777'); ");
     
131.             r = statement.executeQuery("select * from list order by id");
     
132.             System.out.println(r);
     
133.             System.out.println(connection);
     
134.             ResultSetMetaData data=r.getMetaData();
     
135.             System.out.println("列数:"+data.getColumnCount());
     
136.             System.out.println("第一列:"+data.getColumnName(1));
     
137. 
     
138.             int no = 1;
     
139.             /*
     
140.             String temp = result.getString (s);
     
141.             if (temp != null) {
     
142.             byte[] b = temp.getBytes ("8859_1");
     
143.             temp = new String (b);
     
144.             */
     
145. 
     
146.             try {
     
147.                 while (r.next()) {
     
148.                     String temp;
     
149.                     System.out.print(no + ":");
     
150.                     for (int i = 1; i < 8; i++) {
     
151.                         temp = r.getString(i);
     
152.                         //这里用了转码,仍然不好使,
     
153.                         //byte[] b=temp.getBytes("cp437");
     
154.                         //temp=new String(b);
     
155.                         System.out.print(temp);
     
156. 
     
157.                         System.out.print("*");
     
158.                     }
     
159. 
     
160. 
     
161.                     System.out.println();
     
162.                     no++;
     
163.                 }
     
164.             } catch (Exception e) {
     
165.             }
     
166. 
     
167.         } catch (SQLException e) {
     
168.             e.printStackTrace();
     
169.         }
     
170.     }
     
171. 
     
172.     public static void main(String args[]){
     
173.        DB mysql = new DB("mysql", "nothing", "nothing", "bbs");
     
174.        mysql.temp();
     
175. 
     
176. 
     
177. //测试executeUpdate函数,有问题
     
178. 
     
179. 
     
180. //测试geyTableCount()函数  ,有问题
     
181. 
     
182. 
     
183. //测试建立数据表,函数execute，可以
     
184. 
     
185. 
     
186.     }
     
187. 
     
188. 
     
189. }

复制代码