package conn;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.*;
public class stu {
private Connection conn=null;
private Statement stmt=null;
public stu(String dri,String user,String pass,String url){
try {
Class.forName(dri); } catch (Exception e) { System.out.println("加载驱动异常");
}
try {
conn=DriverManager.getConnection(url,user,pass);
if(conn!=null){
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
}
} catch (Exception e) {
System.out.println("数据库链接失败");
}
}
public ResultSet getres(String sql){
ResultSet rs = null;
try { rs=stmt.executeQuery(sql);
if(rs!=null){
return rs;
}else{
return null;
}
} catch (Exception e) {
System.out.println("数据库查询失败");
}
return rs; }
public static void main(String[] args) throws SQLException{
String driver="com.mysql.jdbc.Driver";
String url="jdbc:mysql://localhost:3306/student";
stu mysql=new stu(driver,"root","root",url); for(int i=1;i<100;i++){
String login=readString("请出入查询的用户名:");
if(login.isEmpty()){// 用户输入参数为空!
System.out.println("输入不能为空,请重新查询!");
}
else{
//String sql="select * from stu where login="+"\""+login+"\"";
String sql="select * from stu where login like "+"\""+login+"%"+"\"";
ResultSet rs=mysql.getres(sql); if(rs.next()==false){//判断查询结果为空
System.out.println("无查询结果,请重新查询!");
}
else{
System.out.println("编号 "+" 用户名 "+" 登录名字"+" 密码");
while(rs.next()){
System.out.println(" "+rs.getString(1)+" "+rs.getString(2)+" "+rs.getString(3)+" "+rs.getString(4)); }
rs.close();
}
}
}
} private static String readString(String prompt) {
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
String str = null;
try {
System.out.print(prompt);
str = br.readLine();
} catch (IOException e) {
e.printStackTrace();
}
return str;
}
}
只是查询MYsql数据库的数据,我要一个添加数据的代码,谢谢了,删除的也可以!!
javamysql数据数据库jdbc
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.*;
public class stu {
private Connection conn=null;
private Statement stmt=null;
public stu(String dri,String user,String pass,String url){
try {
Class.forName(dri); } catch (Exception e) { System.out.println("加载驱动异常");
}
try {
conn=DriverManager.getConnection(url,user,pass);
if(conn!=null){
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
}
} catch (Exception e) {
System.out.println("数据库链接失败");
}
}
public ResultSet getres(String sql){
ResultSet rs = null;
try { rs=stmt.executeQuery(sql);
if(rs!=null){
return rs;
}else{
return null;
}
} catch (Exception e) {
System.out.println("数据库查询失败");
}
return rs; }
public static void main(String[] args) throws SQLException{
String driver="com.mysql.jdbc.Driver";
String url="jdbc:mysql://localhost:3306/student";
stu mysql=new stu(driver,"root","root",url); for(int i=1;i<100;i++){
String login=readString("请出入查询的用户名:");
if(login.isEmpty()){// 用户输入参数为空!
System.out.println("输入不能为空,请重新查询!");
}
else{
//String sql="select * from stu where login="+"\""+login+"\"";
String sql="select * from stu where login like "+"\""+login+"%"+"\"";
ResultSet rs=mysql.getres(sql); if(rs.next()==false){//判断查询结果为空
System.out.println("无查询结果,请重新查询!");
}
else{
System.out.println("编号 "+" 用户名 "+" 登录名字"+" 密码");
while(rs.next()){
System.out.println(" "+rs.getString(1)+" "+rs.getString(2)+" "+rs.getString(3)+" "+rs.getString(4)); }
rs.close();
}
}
}
} private static String readString(String prompt) {
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
String str = null;
try {
System.out.print(prompt);
str = br.readLine();
} catch (IOException e) {
e.printStackTrace();
}
return str;
}
}
只是查询MYsql数据库的数据,我要一个添加数据的代码,谢谢了,删除的也可以!!
javamysql数据数据库jdbc
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货