2. 步骤
本文重点接收的是持久化到MySQL中的配置方式：
2.1 添加MySQL驱动
首先需要把MySql的驱动放到ActiveMQ的Lib目录下，我用的文件名字是：mysql-connector-java-5.1.30-bin.jar
2.2 修改配置文件activemq.xml
将其中的这段配置：
修改为下面这段内容：
3、另外需要在节点的下面定义id为mysql-ds的bean，如下：
4、 新建数据库
从配置中可以看出数据库的名称是activemq，需要手动在MySql中新建一个activemq的空数据库。
此时，重新启动MQ，就会发现activemq库中多了三张表：activemq_acks，activemq_lock，activemq_msgs，OK,说明已经持久化成功啦！
创建一个java project；对着project右键->属性 然后就 如图所示：导入mysql-connector-java-5.1.15-bin.jar！然后就可以添加代码来测试了
下面这个嘛 还有界面的
import java.sql.*
import javax.swing.*
import java.awt.*
import java.awt.event.*
import java.util.*
public class Login extends JFrame {
private Connection connection
private Statement statement
private ResultSet resultSet
private ResultSetMetaData rsMetaData
//GUI变量定义
private JTable table
private JTextArea inputQuery
private JButton submitQuery,deleteQuery,insertQuery,alterQuery
public Login()
{
//Form的标题
super( "输入SQL语句，按查询按钮查看结果。" )
String url = "jdbc:mysql://localhost:3306/player"
String username = "root"
String password = "mima1231"
//加载驱动程序以连接数据库
try {
Class.forName( "org.gjt.mm.mysql.Driver" )
connection = DriverManager.getConnection(
url, username, password )
}
//捕获加载驱动程序异常
catch ( ClassNotFoundException cnfex ) {
System.err.println(
"装载 JDBC/ODBC 驱动程序失败。" )
cnfex.printStackTrace()
System.exit( 1 ) // terminate program
}
//捕获连接数据库异常
catch ( SQLException sqlex ) {
System.err.println( "无法连接数据库" )
sqlex.printStackTrace()
System.exit( 1 ) // terminate program
}
//如果数据库连接成功，则建立GUI
//SQL语句
String test="SELECT * FROM user"
inputQuery = new JTextArea( test, 4, 30 )
submitQuery = new JButton( "查询" )
//Button事件
submitQuery.addActionListener(
new ActionListener() {
public void actionPerformed( ActionEvent e )
{
getTable()
}
}
)
insertQuery = new JButton("插入")
deleteQuery = new JButton("删除")
alterQuery = new JButton("修改")
JPanel topPanel = new JPanel()
JPanel buttonPanel = new JPanel()
topPanel.setLayout( new BorderLayout() )
//将"输入查询"编辑框布置到 "CENTER"
topPanel.add( new JScrollPane( inputQuery), BorderLayout.CENTER )
//将"提交查询"按钮布置到 "SOUTH"
buttonPanel.setLayout(new GridLayout(1,4))
buttonPanel.add(submitQuery)
insertQuery.addActionListener(new ActionListener()
{
public void actionPerformed(ActionEvent e)
{
String str = inputQuery.getText()
boolean flag = false
try {
// Statement stat = null
PreparedStatement pstmt = connection.prepareStatement(str)
pstmt.executeUpdate()
flag = true
pstmt.close()
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace()
}
if(flag)JOptionPane.showMessageDialog(null, "数据插入成功")
else JOptionPane.showMessageDialog(null, "数据插入失败")
}
})
buttonPanel.add(insertQuery)
deleteQuery.addActionListener(new ActionListener()
{
public void actionPerformed(ActionEvent e)
{
String str = inputQuery.getText()
boolean flag = false
try {
// Statement stat = null
Statement pstmt = connection.createStatement()
pstmt.executeUpdate(str)
pstmt.close()
flag = true
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace()
}
if(flag)JOptionPane.showMessageDialog(null, "数据删除成功")
else JOptionPane.showMessageDialog(null, "数据删除失败")
}
})
buttonPanel.add(deleteQuery)
alterQuery.addActionListener(new ActionListener()
{
public void actionPerformed(ActionEvent e)
{
String str = inputQuery.getText()
boolean flag = false
try {
Statement pstmt = connection.createStatement()
pstmt.executeUpdate(str)
flag = true
pstmt.close()
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace()
}
if(flag)JOptionPane.showMessageDialog(null, "数据修改成功")
else JOptionPane.showMessageDialog(null, "数据修改失败")
}
})
buttonPanel.add(alterQuery)
topPanel.add( buttonPanel, BorderLayout.SOUTH )
table = new JTable()
Container c = getContentPane()
c.setLayout( new BorderLayout() )
//将"topPanel"编辑框布置到 "NORTH"
c.add( topPanel, BorderLayout.NORTH )
//将"table"编辑框布置到 "CENTER"
c.add( table, BorderLayout.WEST )
getTable()
setSize( 500, 300 )
//显示Form
show()
}
private void getTable()
{
try {
//执行SQL语句
String query = inputQuery.getText()
statement = connection.createStatement()
resultSet = statement.executeQuery( query )
//在表格中显示查询结果
displayResultSet( resultSet )
}
catch ( SQLException sqlex ) {
sqlex.printStackTrace()
}
}
private void displayResultSet( ResultSet rs )
throws SQLException
{
//定位到达第一条记录
boolean moreRecords = rs.next()
//如果没有记录，则提示一条消息
if ( ! moreRecords ) {
JOptionPane.showMessageDialog( this,
"结果集中无记录" )
setTitle( "无记录显示" )
return
}
Vector columnHeads = new Vector()
Vector rows = new Vector()
try {
//获取字段的名称
ResultSetMetaData rsmd = rs.getMetaData()
for ( int i = 1 i <= rsmd.getColumnCount() ++i )
columnHeads.addElement( rsmd.getColumnName( i ) )
//获取记录集
do {
rows.addElement( getNextRow( rs, rsmd ) )
} while ( rs.next() )
//在表格中显示查询结果
table = new JTable( rows, columnHeads )
JScrollPane scroller = new JScrollPane( table )
Container c = getContentPane()
c.remove(1)
c.add( scroller, BorderLayout.CENTER )
//刷新Table
c.validate()
}
catch ( SQLException sqlex ) {
sqlex.printStackTrace()
}
}
private Vector getNextRow( ResultSet rs,
ResultSetMetaData rsmd )
throws SQLException
{
Vector currentRow = new Vector()
for ( int i = 1 i <= rsmd.getColumnCount() ++i )
currentRow.addElement( rs.getString( i ) )
//返回一条记录
return currentRow
}
public void shutDown()
{
try {
//断开数据库连接
connection.close()
}
catch ( SQLException sqlex ) {
System.err.println( "Unable to disconnect" )
sqlex.printStackTrace()
}
}
public static void main( String args[] )
{
final Login app =
new Login()
app.addWindowListener(
new WindowAdapter() {
public void windowClosing( WindowEvent e )
{
app.shutDown()
System.exit( 0 )
}
}
)
}
}
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）