Mysql 与eclipse 数据库的连接


import java.sql.Connection;

import java.sql.DriverManager;

import com.mysql.jdbc.PreparedStatement;

import com.mysql.jdbc.ResultSet;

import com.mysql.jdbc.Statement;

public class mysql2 {

public static void main(String args[]){

SqlWrok wrok=new SqlWrok();

wrok.Init();//初始化函数

wrok.InTo_Sql("yxj","xyj");//插入函数 第一个参数代表的是第一个属性列，第二个参数是代表的第二个属性列的值

wrok.Updata_Sql("jxy136","jxy");//修改 ：同上，但是这连个属性列的值第二个是条件，第一个是要修改的值

wrok.Delete_Sql(1,"jxy");//删除：第一个参数是第几个属性列{1，2，3····n},第二个是条件

wrok.Select_sql();//查询

try{

wrok.psql.executeUpdate();

}

catch(Exception e){

System.out.println("数据库的更新失败");

}

}

}

class SqlWrok{

PreparedStatement psql;

ResultSet res;

String driverName = "com.mysql.jdbc.Driver"; //加载JDBC驱动

String dbURL = "jdbc:mysql://localhost:3306/mysql"; //连接服务器和数据库sample,mysql是数据库的名称，3306是端口

String userName = "root"; //默认用户名

String userPwd = "jxy19910320"; //密码

Connection dbConn=null;

public void Init(){

try {

Class.forName(driverName);

String sql = "select * from student";

dbConn = DriverManager.getConnection(dbURL, userName, userPwd);

Statement stm=(Statement) dbConn.createStatement();

ResultSet rs =(ResultSet) stm.executeQuery(sql);

System.out.println("加载成功！！！");

}

catch (Exception e) {

e.printStackTrace();

System.out.println("加载失败11111");

}

}

public void InTo_Sql(String a,String b){//数据库的信息插入

try{

psql = (PreparedStatement) dbConn.prepareStatement("insert into student values(?,?)");

psql.setString(1, a);

psql.setString(2, b);

psql.executeUpdate();

System.out.println("insert into ···数据库的数据加载成功");

psql.close();

res.close();

}

catch(Exception e){

System.out.println("insert into ···数据的添加失败！");

}

}

public void Select_sql(){//数据库信息的查询

System.out.println("select ······");

System.out.println("学号 "+" 姓名");

String Name=null;

String ID=null;

try{

String sql = "select * from student";

dbConn = DriverManager.getConnection(dbURL, userName, userPwd);

Statement stm=(Statement) dbConn.createStatement();

ResultSet rs =(ResultSet) stm.executeQuery(sql);

while(rs.next()){

Name=rs.getString("name");

ID=rs.getString("number");

System.out.println(ID+" "+Name);

}

psql.close();

res.close();

}

catch(Exception e){

}

}

public void Updata_Sql(String a,String b){//数据库信息的修改

try{

psql=(PreparedStatement) dbConn.prepareStatement

("update student set number = ? where name = ?");

psql.setString(2,b);

psql.setString(1,a);

//psql.setInt(1,a);

System.out.println("updata运行到这里了 ");

psql.executeUpdate();

System.out.println("updata数据的修改已成功");

}

catch(Exception e){

System.out.println("updata数据的修改出现错误！"+e);

}

}

public void Delete_Sql(int a,String b){//数据库信息的删除 a：1，2·· 表示的是第几列 b表示的是第几列的属性值

try{

psql=(PreparedStatement) dbConn.prepareStatement

("delete from student where number= ? ");

psql.setString(1,"120");

//psql.setInt(2,5);

psql.executeUpdate();

System.out.println("数据的删除成功！！！");

//psql.close();

//res.close();

}

catch(Exception e){

System.out.println("数据的删除失败！！！"+e);

}

}

}