用Java *** 作MySQL数据库,如何在读取某些数据同时将其删除

用Java *** 作MySQL数据库,如何在读取某些数据同时将其删除,第1张

不用把取到的所有id拼成一个DELETE语句

比如

String sql="SELECT * FROM 表名 WHERE ******* "

String sql2="DELETE FROM 表名 WHERE ******* "

你把后面的星号里的东西弄成一样的 这样你先执行第一句 然后再执行第二句

前提是你别用联合查询什么的 这样会出问题

创建一个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 )

}

}

)

}

}

你在执行删除之后需要调用updaterow()。就可以看到数据库中的数据变换了。

原因是你使用删除方法之后只是删除了结果集中的数据,但是数据库并没有删除,当你在删除之后在调用更新 *** 作的时候就把结果集中的数据更新回数据库中去,这是数据库中就相当于执行了删除 *** 作就可以看到数据发生变化了。


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/7300100.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-04-04
下一篇 2023-04-04

发表评论

登录后才能评论

评论列表(0条)

保存