jdbc操作mysql数据库

àì夳堔傛蜴生んèń 2022-08-10 09:54 229阅读 0赞

如何操作mysql数据库进行crud：

第一步：创建数据库

DROP TABLE IF EXISTS `jdbc_user`;
    CREATE TABLE `jdbc_user` (
      `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键id',
      `name` varchar(255) DEFAULT NULL COMMENT '户用名',
      `password` varchar(255) DEFAULT NULL COMMENT '户用密码',
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

第二步：导入mysql-connector-java的jar包

第三步：创建实体类：

package com.jdbc.entity;
    
    /**
     * 用户实体类 如果觉得 get / set 方法比较冗余，可以考虑使用lombok
     * 
     * @author ITDragon
     * 
     */
    public class User implements java.io.Serializable {
    	
    	/**
    	 * 第一步：实体类序列化
    	 * 第二步：定义属性
    	 * 第三步：生成get/set方法
    	 * 第四步：创建带主键参数的构造方法
    	 * 第五步：生成toString()方便看结果
    	 */
    
    	private Integer id; // 用户id
    	private String name; // 用户名
    	private String password; // 用户密码
    
    	public User() {
    	}
    
    	public User(Integer id) {
    		this.id = id;
    	}
    
    	public Integer getId() {
    		return id;
    	}
    
    	public void setId(Integer id) {
    		this.id = id;
    	}
    
    	public String getName() {
    		return name;
    	}
    
    	public void setName(String name) {
    		this.name = name;
    	}
    
    	public String getPassword() {
    		return password;
    	}
    
    	public void setPassword(String password) {
    		this.password = password;
    	}
    
    	@Override
    	public String toString() {
    		return "User [id=" + id + ", name=" + name + ", password=" + password
    				+ "]";
    	}
    
    }

第四步：创建链接数据库工具类

package com.jdbc.util;
    
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    
    /**
     * 数据库连接类
     * @author ITDragon
     *
     */
    public class ConnectionUtil {
    	
    	/**
    	 * 第一步：加载驱动
    	 * 第二步：链接数据库
    	 * 第三步：一定要关闭流
    	 * 第四步：测试是否连接成功
    	 */
    	
    	private static String DRIVER = "com.mysql.jdbc.Driver"; 		// 数据库驱动
    	private static String URL = "jdbc:mysql://localhost:3306/test";	// 访问数据库路径
    	private static String NAME = "root";							// 数据库用户名
    	private static String PASSWORD = "root";						// 数据库密码
    
    
    	public static Connection getConnection() {
    		Connection connection = null;
    		try {
    			// 加载驱动
    			Class.forName(DRIVER);
    			// 连接数据库
    			connection = DriverManager.getConnection(URL, NAME, PASSWORD);
    			return connection;
    		} catch (Exception e) {
    			return null;
    		}
    	}
    
    
    	// 关闭流
    	public static void closeConnection(Connection connection) {
    		try {
    			connection.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    
    	public static void closeStatement(Statement statement) {
    		try {
    			statement.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    
    	public static void closePreparedStatement(PreparedStatement pStatement) {
    		try {
    			pStatement.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    
    	public static void closeResultSet(ResultSet rs) {
    		try {
    			rs.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    
    	// 测试数据库是否链接成功
    	public static void main(String[] args) {
    		System.out.println(getConnection());
    	}
    
    
    }

执行出现类似于com.mysql.jdbc.JDBC4Connection@1b8cdd5则表示执行成功

第五步：核心代码

package com.jdbc.dao;
 
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.util.ArrayList;
 import java.util.List;
 import com.jdbc.entity.User;
 import com.jdbc.util.ConnectionUtil;
 
 public class UserDao {
 /**
 * 
 * 插入数据（根据JavaBean的内容插入；所以要导入Dao类） 方法名：saveDao 
 * 创建人：ITDragon 
 * 时间：2015年2月6日-下午8:33:09 
 * 
 * @param dao
 * @return boolean 
 * @exception 
 * @since 1.0.0
 */
 public static boolean saveDao(User user) {
 String sql = "insert into jdbc_user(name,password) values(?,?)";
 Connection connection = null;
 PreparedStatement pStatement = null;
 try {
 connection = ConnectionUtil.getConnection();
 pStatement = connection.prepareStatement(sql);
 pStatement.setString(1, user.getName());
 pStatement.setString(2, user.getPassword());
 int count = pStatement.executeUpdate();
 return count > 0 ? true : false;
 } catch (Exception e) {
 e.printStackTrace();
 return false;
 } finally {
 ConnectionUtil.closePreparedStatement(pStatement);
 ConnectionUtil.closeConnection(connection);
 }
 }
 /**
 * 
 * 查询数据 方法名：findDaos 
 * 创建人：ITDragon 
 * 时间：2015年2月6日-下午8:55:05 
 * 
 * @return List<Dao> 
 * @exception 
 * @since 1.0.0
 */
 public static List<User> findUsers() {
 String sql = "select * from jdbc_user";
 Connection connection = null;
 PreparedStatement pStatement = null;
 ResultSet rs = null;
 List<User> users = null;
 try {
 connection = ConnectionUtil.getConnection();
 pStatement = connection.prepareStatement(sql);
 rs = pStatement.executeQuery();
 users = new ArrayList<User>();
 while (rs.next()) {
 User user = new User();
 user.setId(rs.getInt("id"));
 user.setName(rs.getString("name"));
 user.setPassword(rs.getString("password"));
 users.add(user);
 }
 return users;
 } catch (Exception e) {
 e.printStackTrace();
 return null;
 } finally {
 ConnectionUtil.closeResultSet(rs);
 ConnectionUtil.closePreparedStatement(pStatement);
 ConnectionUtil.closeConnection(connection);
 }
 }
 /**
 * 
 * 根据主键id删除 方法名：deleteUser 
 * 创建人：ITDragon 
 * 时间：2015年2月6日-下午9:03:55 
 * 
 * @param id
 * @return boolean 
 * @exception 
 * @since 1.0.0
 */
 public static boolean deleteUser(Integer id) {
 String sql = "delete from jdbc_user where id = ?";
 Connection connection = null;
 PreparedStatement pStatement = null;
 try {
 connection = ConnectionUtil.getConnection();
 pStatement = connection.prepareStatement(sql);
 pStatement.setInt(1, id);
 int count = pStatement.executeUpdate();
 return count > 0 ? true : false;
 } catch (Exception e) {
 e.printStackTrace();
 return false;
 } finally {
 ConnectionUtil.closePreparedStatement(pStatement);
 ConnectionUtil.closeConnection(connection);
 }
 }
 /**
 * 
 * 根据主键id修改数据 方法名：updateUser 
 * 创建人：ITDragon 
 * 时间：2015年2月6日-下午9:17:03 
 * 
 * @param name
 * @param password
 * @param id
 * @return boolean 
 * @exception 
 * @since 1.0.0
 */
 public static boolean updateUser(String name, String password, Integer id) {
 // name 和 password之间只能用 ","隔开
 String sql = "update jdbc_user set name = ? , password = ? where id = ?";
 Connection connection = null;
 PreparedStatement pStatement = null;
 try {
 connection = ConnectionUtil.getConnection();
 pStatement = connection.prepareStatement(sql);
 pStatement.setString(1, name);
 pStatement.setString(2, password);
 pStatement.setInt(3, id);
 int count = pStatement.executeUpdate();
 return count > 0 ? true : false;
 } catch (Exception e) {
 e.printStackTrace();
 return false;
 } finally {
 ConnectionUtil.closePreparedStatement(pStatement);
 ConnectionUtil.closeConnection(connection);
 }
 }
 }

第六步：测试类

package com.jdbc.test;
 
 import java.util.List;
 
 import org.junit.Test;
 
 import com.jdbc.dao.UserDao;
 import com.jdbc.entity.User;
 
 /**
 * 测试User的crud
 * @author ITDragon
 *
 */
 public class UserTest {
 	
 	@Test
 	public void findUserTest(){
 		List<User> users= UserDao.findUsers();
 		for (User user : users) {
 			System.out.println(user);
 		}
 	}
 	
 	@Test
 	public void saveUserTest(){
 		User user = new User();
 		user.setName("ITDragon");
 		user.setPassword("麻麻说密码太长容易记得");
 		boolean flag = UserDao.saveDao(user);
 		if (flag) {
 			System.out.println(user.getName()+"保存成功");
 		} else {
 			System.out.println("保存失败");
 		}
 	}
 	
 	@Test
 	public void updateUserTest(){
 		boolean flag = UserDao.updateUser("NewITDragon", "麻麻说错了", 1);
 		if (flag) {
 			System.out.println("更新成功");
 		} else {
 			System.out.println("更新失败");
 		}
 	}
 	
 	@Test
 	public void deleteUserTest(){
 		boolean flag = UserDao.deleteUser(1);
 		if (flag) {
 			System.out.println("删除成功");
 		} else {
 			System.out.println("删除失败");
 		}
 	}
 
 }

资料下载地址：[http://download.csdn.net/detail/qq\_19558705/9285827][http_download.csdn.net_detail_qq_19558705_9285827]

个人主页：[http://www.itit123.cn/][http_www.itit123.cn] 更多干货等你来拿

有什么疑问和建议可以留言。

[http_download.csdn.net_detail_qq_19558705_9285827]: http://download.csdn.net/detail/qq_19558705/9285827
[http_www.itit123.cn]: http://www.itit123.cn/