java链接通达OA的mysql数据库操作实例

package com.pac1;

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

import com.mysql.jdbc.Connection;
import java.sql.Statement;

public class mys {

	public mys() {
		// TODO Auto-generated constructor stub
	}
	Connection conn=null;
	public Connection getConnection(){
		try{
			Class.forName("com.mysql.jdbc.Driver");  //加载数据库驱动
			System.out.println("数据库驱动加载成功");
			String url="jdbc:mysql://localhost:3336/TD_OA?useSSL=false";
			//如果不加useSSL=false就会有警告，由于jdbc和mysql版本不同，有一个连接安全问题
			
			String user="root";
			String passWord="y2u8G^6@yj6^_#w1zR1Nu#p@Q";
			//System.out.println("1");
			//Connection对象引的是java.sql.Connection包
			conn=(Connection)DriverManager.getConnection(url,user,passWord); //创建连接
			System.out.println("已成功的与数据库MySQL建立连接！！");
		}catch(Exception e){
			e.printStackTrace();
		}
		return conn;
	}
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		mys mysql= new mys();
		Connection con=mysql.getConnection();
		Statement statement;
		try {
			statement = con.createStatement();
		
		             //要执行的SQL语句
		             String sql = "select * from user limit 5";
		             //3.ResultSet类，用来存放获取的结果集！！
		             ResultSet rs = statement.executeQuery(sql);
		             System.out.println("-----------------");
		             System.out.println("执行结果如下所示:");  
		             System.out.println("-----------------");  
		             System.out.println("姓名" + "t" + "登录账号");  
		             System.out.println("-----------------");  
		             
		             String user_name = null;
		             String byname = null;
		             String user_id = null;
		           while(rs.next()){
		               //获取user_name这列数据
		        	   user_name = rs.getString("user_name");
		               //获取byname这列数据
		        	   byname = rs.getString("byname");
		        	   user_id = rs.getString("user_id");
		                 //输出结果
		               System.out.println(user_id + "t" +byname + "t" + user_name);
		           }
		            String sqlxg = "update user set user_name = '常白' where user_id = 'changbai'";
		            statement.execute(sqlxg);
		            String sqldel = "delete from diary where dia_id=1";
		            statement.execute(sqldel);
		           
		           rs.close();
		           con.close();
		           
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	

}