7-4 自由编程

来源:7-4 自由编程

csm032

2020-04-25 12:11:59

package com.imooc.jdbc.demo;

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import org.junit.Test;

import com.imooc.jdbc.utils.JDBCUtils;
import com.imooc.jdbc.utils.JDBCUtils2;
import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JDBCDemo1 {
	@Test
	public void demo() {
		Connection conn=null;
		PreparedStatement pstmt=null;
		ResultSet rs=null;
		ComboPooledDataSource dataSource=new ComboPooledDataSource();		
		
		try {
			//设置连接池参数
			dataSource.setDriverClass("com.mysql.cj.jdbc.Driver");
			dataSource.setJdbcUrl("jdbc:mysql:///jdbctest?serverTimezone=Hongkong");
			dataSource.setUser("root");
			dataSource.setPassword("123456");
			dataSource.setMaxPoolSize(30);
			dataSource.setInitialPoolSize(3);
			
			conn=dataSource.getConnection();
			String sql="select * from course";
			pstmt=conn.prepareStatement(sql);
			rs=pstmt.executeQuery();
			while(rs.next()) {
				System.out.println(rs.getInt("id")+" "+rs.getString("name")+" "+rs.getString("category")+
						" "+rs.getString("desp")+" "+rs.getTimestamp("createTime"));
			}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			JDBCUtils.release(rs, pstmt, conn);
		}
	}
	
	@Test
	public void demo1() {
		Connection conn=null;
		PreparedStatement pstmt=null;
		ResultSet rs=null;
		try {
			conn=JDBCUtils.getConnection();
			String sql="select * from course";
			pstmt=conn.prepareStatement(sql);
			rs=pstmt.executeQuery();
			while(rs.next()) {
				System.out.println(rs.getInt("id")+" "+rs.getString("name")+" "+rs.getString("category")+
						" "+rs.getString("desp")+" "+rs.getTimestamp("createTime"));
			}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			JDBCUtils2.release(rs, pstmt, conn);
		}
	}

}
package com.imooc.jdbc.utils;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import org.junit.Test;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class JDBCUtils2 {	
	private static final ComboPooledDataSource dataSource=new ComboPooledDataSource();			

	//建立连接
	public static Connection getConnection() throws Exception {				
		Connection conn=dataSource.getConnection();		
		return conn;		
	}
	
	//解除资源占用
	public static void release(ResultSet rs,Statement stmt,Connection conn) {
		if(rs!=null) {
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			rs=null;
		}
		
		if(stmt!=null) {
			try {
				stmt.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			stmt=null;
		}
		
		if(conn!=null) {
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			conn=null;
		}		
	}
	
	//查询数据表信息
	public static String searchInfo(ResultSet rs) throws SQLException {
		String str="";
		while(rs.next()) {
			int id=rs.getInt("id");
			String name=rs.getString("name");
			float price=rs.getFloat("price");
			String desp=rs.getString("desp");
			str=str+id+" "+name+" "+price+" "+desp+'\n';			
		}
		return str;		
	}

}


写回答

1回答

好帮手慕小脸

2020-04-25

同学完成的不错,加油,祝学习愉快~

0

0 学习 · 8016 问题

查看课程

相似问题