实现的功能
在gwt开发中实现,与数据库(oracle)的连接(jdbc),并显示数据记录集,说白了就是在ajax的gwt架构下与数据库交互。
相关工具
gwt1.4,eclipse3.3
首先说明一下要原理分为两部分:客户端部分与服务端部分
如果对gwt的远程调用不怎么清楚,请参见:
http://code.google.com/webtoolkit/documentation/com.google.gwt.doc.DeveloperGuide.RemoteProcedureCalls.html客户端部分 由于客户端只支持jdk1.4的包util与lang(没有jdbc),所以只能自己写一个类存放记录集,如下
public class PeaceResultSet {
private String[] cols;
/**
* @gwt.typeArgs <java.lang.String[]>
*/
private List rows;
public String[] getCols() {
return cols;
}
public void setCols(String[] cols) {
this.cols = cols;
}
public List getRows() {
return rows;
}
public void setRows(List rows) {
this.rows = rows;
}
}
对此类作一个简单的说明。cols是存放列名的,rows是存放记录行的,请注意在它前面的那一个注释(/**
* @gwt.typeArgs <java.lang.String[]>
*/),一定不能少的,因为,最终这个java代码会被转换成javascript,这里告诉转换的类型的
有了记录集,我们就可以用FlexTable来把我们的记录集显示出来了,如下
public class PeaceTable extends Composite{
private FlexTable table = new FlexTable();
public FlexTable getTable() {
return table;
}
public PeaceTable() {
this.initWidget(table);
}
public void showResultSet(PeaceResultSet re)
{
this.table.clear();
if(re != null && re.getRows()!= null && re.getRows().size()>0)
{
String[] cols = re.getCols();
List rows = re.getRows();
for(int j = cols.length-1; j >= 0; j--)
{
table.setText(0,j,cols[j]);
}
for(int i = 0; i < rows.size(); i++)
{
cols = (String[])rows.get(i);
for(int j = cols.length-1; j >= 0; j--)
{
table.setText(i+1,j,cols[j]);
}
}
}
else
{
table.setText(0,0,"no data");
}
}
public void callServer(String sql) {
PeaceSelectResultSetAsync.Util.getInstance().select(sql, new AsyncCallback() {
public void onFailure(Throwable caught) {
}
public void onSuccess(Object result) {
showResultSet((PeaceResultSet) result);
}
});
}
服务端部分这一部分是完全的java,可以用java可以使用的全部库(当然自己写的也可以)
我这里用的是jdbc来连接数据库(只是最简单的,因为这里不是说明数据怎么操作的),代码如下
public class PeaceSelectResultSetImpl extends RemoteServiceServlet implements
PeaceSelectResultSet {
private static final long serialVersionUID = 1L;
public PeaceResultSet select(String sql) {
Connection conn = null;
Statement stmt = null;
ResultSet se = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
String url = "jdbc:oracle:thin:@192.168.1.11:1521:XXXX"; // orclΪ��ݿ��SID
String user = "uuser";
String password = "pwd";
conn = DriverManager.getConnection(url, user, password);
stmt = conn.createStatement();
se = stmt.executeQuery(sql);
ResultSetMetaData rsmd = se.getMetaData();
String[] cols = new String[rsmd.getColumnCount()];
List rows = new ArrayList();
for (int i = cols.length; i > 0; i--) {
cols[i - 1] = rsmd.getColumnName(i);
}
while (se.next()) {
String[] row = new String[cols.length];
rows.add(row);
for (int i = cols.length - 1; i >= 0; i--) {
row[i] = se.getString(cols[i]);
}
}
PeaceResultSet kfse = new PeaceResultSet();
kfse.setCols(cols);
kfse.setRows(rows);
return kfse;
} catch (Exception e) {
e.printStackTrace();
} finally {
if (se != null)
try {
se.close();
} catch (SQLException e1) {
e1.printStackTrace();
}
if (stmt != null)
try {
stmt.close();
} catch (SQLException e1) {
e1.printStackTrace();
}
if (conn != null)
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
return null;
}
}
在下一部分中,我将说明一些注意事项,以及给出完整的源代码!!