JDBC实例

时间  2020-05-05
标签 jdbc 实例 栏目 Java 繁體版
原文   原文链接

JDBC实例java

 

一、经过statement存入一个学生，查询学生sql

二、经过prestatement存入一个学生数据库

 

 

ExamStudent对象类：ide

package jdbc2;

public class ExamStudent {
	int flowid;
	int type;
	String idcard;
	String examCard;
	String studentname;
	String location;
	int grade;
	public ExamStudent() {
		super();
		// TODO Auto-generated constructor stub
	}
	
	@Override
	public String toString() {
		return "ExamStudent [flowid=" + flowid + ", type=" + type + ", idcard="
				+ idcard + ", examCard=" + examCard + ", studentname="
				+ studentname + ", location=" + location + ", grade=" + grade
				+ "]";
	}
	public int getFlowid() {
		return flowid;
	}
	public void setFlowid(int flowid) {
		this.flowid = flowid;
	}
	public int getType() {
		return type;
	}
	public void setType(int type) {
		this.type = type;
	}
	public String getIdcard() {
		return idcard;
	}
	public void setIdcard(String idcard) {
		this.idcard = idcard;
	}
	public String getExamCard() {
		return examCard;
	}
	public void setExamCard(String examCard) {
		this.examCard = examCard;
	}
	public String getStudentname() {
		return studentname;
	}
	public void setStudentname(String studentname) {
		this.studentname = studentname;
	}
	public String getLocation() {
		return location;
	}
	public void setLocation(String location) {
		this.location = location;
	}
	public int getGrade() {
		return grade;
	}
	public void setGrade(int grade) {
		this.grade = grade;
	}

	public ExamStudent(int flowid, int type, String idcard, String examCard,
			String studentname, String location, int grade) {
		super();
		this.flowid = flowid;
		this.type = type;
		this.idcard = idcard;
		this.examCard = examCard;
		this.studentname = studentname;
		this.location = location;
		this.grade = grade;
	}
}

　　

一、获取数据库链接封装的方法测试

public static Connection getConnection() throws Exception{
		String driverClass = null;
		String url = null;
		String user = null;
		String password = null;
		
		//读取properties配置文件
		InputStream is = TestJDBC.class.getClassLoader().getResourceAsStream("jdbc.properties");
		Properties properties = new Properties();
		properties.load(is);
	    driverClass = properties.getProperty("driverClass");
	    url = properties.getProperty("url");
		user = properties.getProperty("user");
		password = properties.getProperty("password");
		
		//加载数据库驱动（对应的Driver实现类中有注册驱动的静态代码块）
		Class.forName(driverClass);
		
		Properties info = new Properties();
		info.put("user", user);
		info.put("password", password);
		
		//经过DriverManager的getConnection()方法获取数据库链接
		return DriverManager.getConnection(url, user, password);
	}

 

二、释放资源封装的方法

this

//释放资源
	public static void release(Statement statement,Connection conn,ResultSet rs){
		if(rs != null){
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if(statement!=null){
			try {
				statement.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if(conn != null){
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

　　

三、简单的学生登陆封装的方法url

//登陆
	private int getSearchTypeFormConsole(){
		System.out.println("请输入登陆类型：1：身份证登陆  2.准考证号登录");
		Scanner sc = new Scanner(System.in);
		int type = sc.nextInt();
		if(type != 1 && type != 2){
			throw new RuntimeException("输入类型有误");
		}
		
		return type;
	}

　　

四、建立查询语句spa

public String SearchStudent(int type){
		ExamStudent es = new ExamStudent();
		Scanner sc = new Scanner(System.in);
		String sql = "select * from ExamStudent where idcard = " ;
		if(type == 1){
			System.out.println("请输入身份证号");
			
			String idcard = sc.next();
			es.setIdcard(idcard);
			sql = sql + es.getIdcard();
		}else{
			System.out.println("请输入准考证号");
			String examcard = sc.next();
			es.setExamCard(examcard);
			sql = sql + es.getExamCard();
		}
		return sql;
		
	}

　　

五、查询学生rest

public ExamStudent getStudent(String sql){
		Connection conn = null;
		Statement statement = null;
		ResultSet rs = null;
		ExamStudent es = null;
		
		try {
			conn = getConnection();
			statement = conn.createStatement();
			rs = statement.executeQuery(sql);
			
			while(rs.next()){
				es = new ExamStudent(
						rs.getInt(1),
						rs.getInt(2),
						rs.getString(3),
						rs.getString(4),
						rs.getString(5),
						rs.getString(6),
						rs.getInt(7));
			}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			release(statement, conn, rs);
		}
		return es;	
	}

　　

六、输出学生code

public void printStudent(ExamStudent es){
		if(es !=null){
			System.out.println(es);
		}else{
			System.out.println("查无此人！！！");
		}
	}

　　

七、测试

@Test
	public void test1() throws Exception{
		//1.登陆
		int type = getSearchTypeFormConsole();
		
		//获取信息
		String sql = SearchStudent(type);
		
		//查询
		ExamStudent es = getStudent(sql);
		
		//输出
		printStudent(es);
	}

　　

 

八、从控制台输入ExamStudent对象

//从控制台输入ExamStudent对象
	public ExamStudent getExamStudentFromConsole(){
		ExamStudent es = new ExamStudent();
		Scanner sc = new Scanner(System.in);
		System.out.println("学生号： ");
		es.flowid = sc.nextInt();
		System.out.println("考试类型： ");
		es.type = sc.nextInt();
		System.out.println("身份证： ");
		es.idcard = sc.next();
		System.out.println("考号： ");
		es.examCard = sc.next();
		System.out.println("学生名： ");
		es.studentname = sc.next();
		System.out.println("学生地址： ");
		es.location = sc.next();
		System.out.println("学生班级： ");
		es.grade = sc.nextInt();
		return es;
	}

　　

九、封装的sql语句修改、插入、删除方法

public void update(String sql){
		Connection conn = null;
		Statement statement = null;
		ResultSet rs = null;
		try {
			conn = getConnection();
			statement = conn.createStatement();
			statement.executeUpdate(sql);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			TestJDBC.release(statement, conn,rs);
		}
	}

　　

十、添加学生

//添加学生到数据库
	public void addStudent(){
		ExamStudent stu  = getExamStudentFromConsole();
		String sql = "insert into examstudent values(" + stu.getFlowid() +"," + stu.getType() + ",'" + stu.getIdcard() + "','" + stu.getExamCard() + "','" + stu.getStudentname() + "','" + stu.getLocation() + "'," + stu.getGrade() + ")";
		update(sql);
		System.out.println("插入成功！！！！");
	}

　　

 

经过Prestatement存入学生数据

一、从控制台获得须要插入的学生信息

 

//从控制台输入ExamStudent对象
	public ExamStudent getExamStudentFromConsole(){
		ExamStudent es = new ExamStudent();
		Scanner sc = new Scanner(System.in);
		System.out.println("学生号： ");
		es.flowid = sc.nextInt();
		System.out.println("考试类型： ");
		es.type = sc.nextInt();
		System.out.println("身份证： ");
		es.idcard = sc.next();
		System.out.println("考号： ");
		es.examCard = sc.next();
		System.out.println("学生名： ");
		es.studentname = sc.next();
		System.out.println("学生地址： ");
		es.location = sc.next();
		System.out.println("学生班级： ");
		es.grade = sc.nextInt();
		return es;
	}

 

　　

 

二、获取数据库链接

//获取数据库链接方法
	public static Connection getConnection() throws Exception{
		String driverClass = null;
		String url = null;
		String user = null;
		String password = null;
		
		//读取properties配置文件
		InputStream is = TestJDBC.class.getClassLoader().getResourceAsStream("jdbc.properties");
		Properties properties = new Properties();
		properties.load(is);
	    driverClass = properties.getProperty("driverClass");
	    url = properties.getProperty("url");
		user = properties.getProperty("user");
		password = properties.getProperty("password");
		
		//加载数据库驱动（对应的Driver实现类中有注册驱动的静态代码块）
		Class.forName(driverClass);
		
		Properties info = new Properties();
		info.put("user", user);
		info.put("password", password);
		
		//经过DriverManager的getConnection()方法获取数据库链接
		return DriverManager.getConnection(url, user, password);
	}

　　

三、经过prestatement进行数据插入

//重写update方法
	public void update(String sql,Object...args){
		Connection conn = null;
		PreparedStatement preparedStatement = null;
		
		try {
			conn = getConnection();
			preparedStatement = conn.prepareStatement(sql);
			
			for(int i=0;i<args.length;i++){
				preparedStatement.setObject(i+1, args[i]);
			}
			int result = preparedStatement.executeUpdate();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

　　

四、添加学生

//添加学生
	public void addStudent2(ExamStudent es){
		String sql = "insert into examstudent(flowid,type,idcard,examcard,studentname,location,grade) values(?,?,?,?,?,?,?)";
		update(sql,es.getFlowid(),es.getType(),es.getIdcard(),es.getExamCard(),es.getStudentname(),es.getLocation(),es.getGrade());
	}

　　

五、进行测试

@Test
	public void test3(){
		ExamStudent es = getExamStudentFromConsole();
		addStudent2(es);
	}
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程