设为首页 加入收藏

TOP

mysql数据库的连接以及增删改查Java代码实现(Statement版)(一)
2015-07-24 12:09:44 来源: 作者: 【 】 浏览:60
Tags:mysql 数据库 连接 以及 删改 Java 代码 实现 Statement

数据库

create table t1(id int primary key not null auto_increment,name varchar(32),password varchar(32));

insert into t1(name,password) values('admin','123');
insert into t1(name,password) values('zhangsan','123');
insert into t1(name,password) values('lisi','123');

Java代码:

mysqlDao.java:

package com.dao;

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

import org.junit.Test;

public class mysqlDao {
	
	private static String driver="com.mysql.jdbc.Driver";     //驱动
	private String url="jdbc:mysql://localhost:3306/test";    //数据库连接地址
	private String user="root";     //数据库账户
	private String password="11";      //数据库密码
	
	private Connection connection=null;      //连接
	private Statement stmt=null;      //声明
	private ResultSet rs=null;     //结果集
	
	private int i=-1;
	
	/*
	 * 创建驱动
	 * */
	static{
		try {
			Class.forName(driver);
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/*
	 * 加载驱动
	 * */
	@Test
	public void connect() {
		// TODO Auto-generated method stub
		try {
			
			connection=DriverManager.getConnection(url, user, password);
			
			if(connection!=null){
				System.out.println("数据库连接成功!");
			}else{
				System.out.println("数据库连接失败!");
			}
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/*
	 * 执行sql语句
	 * */
	public void doSql(String sql) {
		// TODO Auto-generated method stub
		
		System.out.println("This Is mysqlDao.doSql() Method!");
		
		if(sql!=null){
			connect();
			
			try {
				
				stmt=connection.createStatement();
				stmt.execute(sql);
				
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
	}
	
	/*
	 * 获取影响行数
	 * */
	public int getUpCount() {
		// TODO Auto-generated method stub
		
		try {
			i=stmt.getUpdateCount();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return i;
	}
	
	/*
	 * 获取结果集
	 * */
	public ResultSet getRs() {
		
		try {
			rs=stmt.getResultSet();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return rs;
	}
	
	/*
	 * 执行关闭方法
	 * */
	public void close() {
		// TODO Auto-generated method stub
		
			try {
				if(rs!=null){
				rs.close();
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				
					try {
						
						if(stmt!=null){
						stmt.close();
						}
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}finally{
						if(connection!=null){
							try {
								connection.close();
							} catch (SQLException e) {
								// TODO Auto-generated catch block
								e.printStackTrace();
							}
						}
					}
				}
				
	}

}

createSql.java

package com.dao;

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

import org.junit.Test;

public class createSql {
	
	mysqlDao mysqldao=new mysqlDao();
	
	private String sql;
	private int i=-1;
	
	private ResultSet rs=null;
	
	/*
	 * 插入数据
	 * */
	@Test
	public void insert() {
		// TODO Auto-generated meth
首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇mysqldump全备份脚本mysqlallback.. 下一篇net stop mysql或者是net start m..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: