Java与MYSQL连接的精典例子,用Swing显示
import java.sql.*;
importjavax.swing.*;
importjava.awt.*;
importjava.awt.event.*;
import java.util.*;public class inensshow extends JFrame {
privateConnectionconnection;
privateStatementstatement;
privateResultSetresultSet;
private ResultSetMetaData rsMetaData;//GUI变量定义
privateJTabletable;
privateJTextAreainputQuery;
private JButton submitQuery;public inensshow()
{
//Form的标题
super( "输入SQL语句,按查询按钮查看结果。" );String url = "jdbc:mysql://localhost:3306/test";
Stringusername="root";
Stringpassword="000000";
//加载驱动程序以连接数据库
try{
Class.forName("org.gjt.mm.mysql.Driver");
connection=DriverManager.getConnection(
url,username,password);
}
//捕获加载驱动程序异常
catch(ClassNotFoundExceptioncnfex){
System.err.println(
"装载JDBC/ODBC驱动程序失败。");
cnfex.printStackTrace();
System.exit(1);//terminateprogram
}
//捕获连接数据库异常
catch(SQLExceptionsqlex){
System.err.println("无法连接数据库");
sqlex.printStackTrace();
System.exit(1);//terminateprogram
}
//如果数据库连接成功,则建立GUI
//SQL语句
Stringtest="SELECT*FROMabout";
inputQuery=newJTextArea(test,4,30);
submitQuery=newJButton("查询");
//Button事件
submitQuery.addActionListener(
newActionListener(){
publicvoidactionPerformed(ActionEvente)
{
getTable();
}
}
);JPanel topPanel = new JPanel();
topPanel.setLayout(newBorderLayout());
//将"输入查询"编辑框布置到"CENTER"
topPanel.add(newJScrollPane(inputQuery),BorderLayout.CENTER);
//将"提交查询"按钮布置到"SOUTH"
topPanel.add(submitQuery,BorderLayout.SOUTH);
table=newJTable();
Containerc=getContentPane();
c.setLayout(newBorderLayout());
//将"topPanel"编辑框布置到"NORTH"
c.add(topPanel,BorderLayout.NORTH);
//将"table"编辑框布置到"CENTER"
c.add(table,BorderLayout.CENTER);
getTable();
setSize(500,300);
//显示Form
show();
}private void getTable()
{
try{
//执行SQL语句
Stringquery=inputQuery.getText();
statement=connection.createStatement();
resultSet=statement.executeQuery(query);
//在表格中显示查询结果
displayResultSet(resultSet);
}
catch(SQLExceptionsqlex){
sqlex.printStackTrace();
}
}private void displayResultSet( ResultSet rs )
throwsSQLException
{
//定位到达第一条记录
booleanmoreRecords=rs.next();
//如果没有记录,则提示一条消息
if(!moreRecords){
JOptionPane.showMessageDialog(this,
"结果集中无记录");
setTitle("无记录显示");
return;
}
VectorcolumnHeads=newVector();
Vectorrows=newVector();
try{
//获取字段的名称
ResultSetMetaDatarsmd=rs.getMetaData();
for(inti=1;i<=rsmd.getColumnCount();++i)
columnHeads.addElement(rsmd.getColumnName(i));
//获取记录集
do{
rows.addElement(getNextRow(rs,rsmd));
}while(rs.next());
//在表格中显示查询结果
table=newJTable(rows,columnHeads);
JScrollPanescroller=newJScrollPane(table);
Containerc=getContentPane();
c.remove(1);
c.add(scroller,BorderLayout.CENTER);
//刷新Table
c.validate();
}
catch(SQLExceptionsqlex){
sqlex.printStackTrace();
}
}privateVectorgetNextRow(ResultSetrs,
ResultSetMetaDatarsmd)
throwsSQLException
{
VectorcurrentRow=newVector();
for(inti=1;i<=rsmd.getColumnCount();++i)
currentRow.addElement(rs.getString(i));
//返回一条记录
returncurrentRow;
}public void shutDown()
{
try{
//断开数据库连接
connection.close();
}
catch(SQLExceptionsqlex){
System.err.println("Unabletodisconnect");
sqlex.printStackTrace();
}
}public static void main( String args[] )
{
finalinensshowapp=newinensshow();
app.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente)
{
app.shutDown();
System.exit(0);
}
}
);
}
}