Java对数据库操作增删改查
SQL新增数据
//SQL新增数据
public static void zengSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库,实现新增数据
Statement sql = con.createStatement();
String new_member = "insert into sqls(sql1,sql2,sql3) values('表单值1','表单值2','表单值3')";
//一次增加多条数据
//String new_member="insert into 表名(表单名1,表单名2)"
//new_menber += "values('表单值1','表单值2'),";
//new_menber += "('表单值1','表单值2')";
//4.执行发送
sql.executeUpdate(new_member);
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
SQL查找数据
//SQL查找数据
public static void chaSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库,实现查找数据
Statement sql = con.createStatement();
//4.执行发送
ResultSet rs = sql.executeQuery("select * from sqls");
//5.打印数据表结果
while (rs.next()) {
System.out.println(rs.getString("sql1"));//表单名,即表头//数据库设计时,表头使用英文
}
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
SQL修改数据
//SQL修改数据
public static void gaiSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库
Statement sql = con.createStatement();
// String new_member = "update sqls set sql1='表单值123',sql2='表单值2345' where sql2=10";
String new_member = "update sqls set sql1='表单值123',sql2='表单值2345'";
//name='qjh' where id=1;
//4.发送执行
sql.executeUpdate(new_member);
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
SQL删除数据
//SQL删除数据
public static void shanSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库
Statement sql = con.createStatement();
// String new_member = "delete from sqls where sql1 = 'sql2'";
//String new_member = "delete from sqls where sql4='1'"; //删除某行
String new_member = "ALTER TABLE sqls CHANGE 'sql3' 'sql22' VARCHAR(10)"; //修改某行字段
sql.executeUpdate(new_member);
//4.发送执行
sql.executeUpdate(new_member);
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
注意事项 接口写法必须有 SQLException 方法,否则会报错。
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
实例:
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class DemoApplication {
private static String URL = "jdbc:mysql://101.43.123.237:3306/sql_liwnute_com";//jdbc:mysql//服务器地址/数据库名
private static String USER = "sql_liwnute_com";//用户名
private static String PASSWORD = "rootroot";//密码
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
System.out.println("\n开始:\n"); //打印异常
zengSQL();
chaSQL();
gaiSQL();
shanSQL();
}
//SQL新增数据
public static void zengSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库,实现新增数据
Statement sql = con.createStatement();
String new_member = "insert into sqls(sql1,sql2,sql3) values('表单值1','表单值2','表单值3')";
//一次增加多条数据
//String new_member="insert into 表名(表单名1,表单名2)"
//new_menber += "values('表单值1','表单值2'),";
//new_menber += "('表单值1','表单值2')";
//4.执行发送
sql.executeUpdate(new_member);
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
//SQL查找数据
public static void chaSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库,实现查找数据
Statement sql = con.createStatement();
//4.执行发送
ResultSet rs = sql.executeQuery("select * from sqls");
//5.打印数据表结果
while (rs.next()) {
System.out.println(rs.getString("sql1"));//表单名,即表头//数据库设计时,表头使用英文
}
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
//SQL修改数据
public static void gaiSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库
Statement sql = con.createStatement();
// String new_member = "update sqls set sql1='表单值123',sql2='表单值2345' where sql2=10";
String new_member = "update sqls set sql1='表单值123',sql2='表单值2345'";
//name='qjh' where id=1;
//4.发送执行
sql.executeUpdate(new_member);
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
//SQL删除数据
public static void shanSQL() {
//private static final String URL="jdbc:mysql://localhost:3306/数据库名";//jdbc:mysql//服务器地址/数据库名
//private static final String USER="用户名";//用户名
//private static final String PASSWORD="密码";//密码
try {
//1.加载驱动程序 此语句固定,使用MySQL数据库无需更改,在JSP中可不加异常处理
//Class.forName("com.mysql.jdbc.Driver");
//2.建立数据库的连接
Connection con = DriverManager.getConnection(URL,USER,PASSWORD);
//3.通过数据库的连接操作数据库
Statement sql = con.createStatement();
// String new_member = "delete from sqls where sql1 = 'sql2'";
//String new_member = "delete from sqls where sql4='1'"; //删除某行
String new_member = "ALTER TABLE sqls CHANGE 'sql3' 'sql22' VARCHAR(10)"; //修改某行字段
sql.executeUpdate(new_member);
//4.发送执行
sql.executeUpdate(new_member);
con.close();//断开数据库连接
}
catch(SQLException E) {
System.out.println("SQL异常!!!!");
System.out.println(E); //打印异常
}
}
}
684 Views