您的位置:首页 > 编程语言 > Java开发

java链接mysql数据库

2015-06-28 13:00 405 查看
package com.dezhonger;

import java.sql.*;

public class shiyan6 {
	public static void print(ResultSet rs) throws SQLException
	{
		while(rs.next())
		{
			String name = rs.getString("name");
			String sno = rs.getString("sno");
			String sex = rs.getString("sex");
			System.out.print(name);
			System.out.print(" ");
			System.out.print(sno);
			System.out.print(" ");
			System.out.println(sex);
			System.out.println();
		}
	}

	public static void main(String[] args) throws SQLException {
		String url="jdbc:mysql://localhost:3306/javashiyan6";  //javashiyan6是数据库名
	    String user="root";
	    String pwd="123456";
	    String selectSql = "select * from info";//info是表名
	    String insertSql = "insert into info values('马万群', '201216010312', '女')";
	    String updateSql = "update info set sex = '男' where sno = '201216010312'";
	    String deleteSql = "delete from info where sno = '201216010312'";
		try {
			Class.forName("com.mysql.jdbc.Driver");
			Connection conn = DriverManager.getConnection(url,user, pwd);
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(selectSql);
			print(rs);
			
			int count = stmt.executeUpdate(insertSql);
			System.out.println("插入了" + count + "记录");
			rs = stmt.executeQuery(selectSql);
			print(rs);
			
			count = stmt.executeUpdate(updateSql);
			System.out.println("修改了" + count + "记录");
			rs = stmt.executeQuery(selectSql);
			print(rs);
			
			count = stmt.executeUpdate(deleteSql);
			System.out.println("删除了" + count + "记录");
			rs = stmt.executeQuery(selectSql);
			print(rs);
			
			
			
			rs.close();
			conn.close();
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			System.err.println("error");
		}

	}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: