Java数据库之数据库的连接操作

package mysql_demo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.mysql.jdbc.Statement;

public class mysql_demo {

	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		// TODO Auto-generated method stub
		//1.注册启动，使用反射技术，固定格式
				Class.forName("com.mysql.jdbc.Driver");
				
				//2.获取数据库连接，DriverManager类中的静态方法
				//static Connection getConnection(String url,String user,String password)
				//返回值是Connection接口的实现类，在mysql驱动程序中
				//url的格式：数据库地址 jdbc:mysql://连接主机IP：端口号//数据库名字
				String url = "jdbc:mysql://localhost:3306/mybase";
				String root = "***";
				String password = "***";
				Connection con = DriverManager.getConnection(url,root,password);
//				System.out.println(con);
				
				//3.获取语句执行平台，通过数据库连接对象，获取到SQL语句的执行者对象
				//con对象调用方法，Statement createStatement() 获取Statement对象，将SQL语句发送到数据库
				//返回值是Statement接口的实现类对象，在mysql驱动程序中
				Statement stat = (Statement) con.createStatement();
				
				//4.执行sql语句
				//通过执行者对象调用方法执行SQL语句，获取结果 
				//int executeUpdate(String sql)   执行数据库中的SQL语句，inset,delete,update
				//返回值是int,操作成功数据表多少行
//				String sql = "INSERT INTO sort(sname,sprice,sdesc) VALUES(‘手机11‘,‘5999‘,‘iphone11‘)";
//				int row = stat.executeUpdate(sql);
//				System.out.println(row);
				
				
				//查询SQL语句
				String sql = "SELECT * FROM sort";
				//ReaultSet executeQuery(String sql) 执行SQL语句中的select查询
				//返回值ResultSet接口的实现类对象，实现类在mysql驱动中
				ResultSet rs = stat.executeQuery(sql);
				System.out.println(rs);
				
				while(rs.next()){
					//获取每列的数据，使用的是ResultSet接口的getXXX方法,写String列名
					System.out.println(rs.getInt("sid")+"   "+rs.getString("sname")+"   "+rs.getDouble("sprice")+"   "+rs.getString("sdesc"));
				}
				
				//6.释放资源
				rs.close();
				stat.close();
				con.close();
	}

}

package mysql_demo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

import com.mysql.jdbc.PreparedStatement;

public class mysql_update {

	/*
	 * 使用PrepareStatement接口实现数据表的更新操作
	 * 
	 * */
	public static void main(String[] args) throws ClassNotFoundException, SQLException {
		// TODO Auto-generated method stub
		
		//注册驱动
		Class.forName("com.mysql.jdbc.Driver");
		//获取连接对象
		String url = "jdbc:mysql://localhost:3306/mybase";
		String username = "***";
		String password = "***";
		Connection con = DriverManager.getConnection(url,username,password);
		//拼写修改的SQL语句，参数用？
		String sql = "Update sort SET sname = ?,sprice=? WHERE sid = ?";
		//调用连接对象con的方法prepareStatement来获取sql语句的预编译对象
		PreparedStatement pst = (PreparedStatement) con.prepareStatement(sql);
		pst.setObject(1, "娃哈哈");
		pst.setObject(2, 111);
		pst.setObject(3, 7);
		System.out.println(pst);
		
		//执行SQL语句
		pst.executeUpdate();
		
		//关闭资源
		pst.close();
		con.close();
	}

}

package mysql_demo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;

import com.mysql.jdbc.PreparedStatement;

public class mysql_select {
	public static void main(String[] args) throws Exception{
		//注册驱动
		Class.forName("com.mysql.jdbc.Driver");
		//获取连接对象
		String url = "jdbc:mysql://localhost:3306/mybase";
		String username = "***";
		String password = "***";
		Connection con = DriverManager.getConnection(url,username,password);
		
		String sql = "SELECT * FROM sort";
		PreparedStatement pst = (PreparedStatement) con.prepareStatement(sql);
		
		//调用pst对象的方法，实现查询操作
		ResultSet rs = pst.executeQuery();
		while(rs.next()){
			System.out.println(rs.getString("sid")+"   "+rs.getString("sname")+"   "+rs.getString("sprice")+"   "+rs.getString("sdesc"));
		}
		//关闭资源
		rs.close();
		pst.close();
		con.close();
	}
}