package com.soft.dao;
import java.sql.*;
public class BaseDao {
Connection conn;
PreparedStatement pst;
ResultSet ret;
//连接数据库
public BaseDao(){
try {
Class.forName("com.mysql.jdbc.Driver");
conn=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/jdbc_02","root","wyroot123");
if(conn!=null){
System.out.println("数据库连接成功");
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
//查询数据库
public ResultSet queryDB(String sql){
return queryDB(sql,null);
}
//带参数查询数据库
public ResultSet queryDB(String sql,Object[] param){
try {
pst=conn.prepareStatement(sql);//预编译Sql
if(param!=null&¶m.length>0){
for(int i=0;i<param.length;i++){
pst.setObject(i+1,param[i]);
}
}
ret=pst.executeQuery();//执行Sql,获取结果集
} catch (SQLException e) {
e.printStackTrace();
}
return ret;
}
//dm1---update insert dalete
public int dm1(String sql,Object[] param){
int ret=0;
try {
pst=conn.prepareStatement(sql);//预编译
if(param!=null&¶m.length>0){
for(int i=0;i<param.length;i++){
pst.setObject(i+1,param[i]);
}
}
ret=pst.executeUpdate();//执行dml
} catch (SQLException e) {
e.printStackTrace();
}
return ret;
}
public static void main(String[] args) {
BaseDao dao = new BaseDao();
//操作结果集
try {
// PreparedStatement pst=conn.prepareStatement("select * from tuser where uid=?");//预编译Sql
// pst.setObject(1,20221111172200);
// ResultSet ret=pst.executeQuery();//执行Sql,获取结果集
Object[] param=new Object[]{};
dao.dm1("insert into tuser values(?,?,?,?,?,?)",param);
ResultSet ret= dao.queryDB("select * from tuser",null);
while ( ret.next()){
System.out.println("用户名:"+ret.getString("uname")+"密码:"+ret.getString("pass"));
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}