一套完整的JDBC增删改查程序:
package com.jdbc.zsgc;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import com.mysql.jdbc.Connection;
public class Demo1 {
public static void main(String[] args) throws Exception
{
func1();
func2();
}
//数据库增、删、改数据
static void func1() throws Exception
{
Connection conn=null;//定义Connection
Statement sm=null;//定义Statement
try
{
Class.forName("com.mysql.jdbc.Driver");//加载驱动类
String url="jdbc:mysql://localhost:3306/mydb3";//主机:端口号/数据库
String user="root";//数据库登录用户名
String pwd="root";//数据库登录密码
conn=(Connection)DriverManager.getConnection(url,user,pwd);//得到连接对象
sm=conn.createStatement();//得到Statement,发送select语句
String sql="insert into Table_stu values('NO_0004','wangwu',35,'male')";//数据库操作语句,插入数据
String sql1="update Table_stu set name='zhaoliu',age=22,gender='female' where number='NO_0003'";//数据库操作语句,修改数据
String sql2="delete from Table_stu where number='NO_0004'";//数据库操作语句,删除数据
int r= sm.executeUpdate(sql);//接收返回受影响行数
System.out.println("执行成功,"+"影响"+r+"行");
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
if(sm!=null)sm.close();//关闭sm
if(conn!=null)conn.close();//关闭conn
}
}
//数据库查询数据
static void func2()throws Exception
{
Connection conn=null;//定义Connection
Statement sm=null;//定义Statement
ResultSet rs=null;//定义ResultSet
try
{
Class.forName("com.mysql.jdbc.Driver");//加载驱动类
String url="jdbc:mysql://localhost:3306/mydb3";//数据库连接地址
String user="root";//数据库登录用户名
String pwd="root";//数据库登录密码
conn=(Connection)DriverManager.getConnection(url,user,pwd);//得到连接对象
sm=conn.createStatement(); //得到Statement,发送select语句
String sql="select * from Table_stu";
rs=sm.executeQuery(sql);//得到返回的结果集
System.out.println("查询结果:");
while(rs.next())//把光标移到下一行,如果下一行有效,在进行操作
{
String number=rs.getString(1);
String name=rs.getString(2);
int age=rs.getInt(3);
String gender=rs.getString(4);
System.out.println(number+","+name+","+age+","+gender);//输出表的查询结果
}
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
if(rs!=null)rs.close();//关闭rs
if(sm!=null)sm.close();//关闭sm
if(conn!=null)conn.close();//关闭conn
}
}
}