JAVA操作Mysql数据库（JDBC）

/*

* Created on 2008-12-31

* Copyright 2008 by Springs Design Inc. All Rights Reserved

*

*/

package net.xfok.db;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

/**

* @author YangHua

* 转载请注明出处：http://www.xfok.net/2009/10/134513.html

*/

public class DBMysql {

public Connection conn=null;

/**

* 连接数据库

* @param dbPath

* @return

* @throws Exception

*/

public Statement getStatement(String host,String user,String pass,String dbName) throws Exception{

Class.forName("org.gjt.mm.mysql.Driver").newInstance();

String url ="jdbc:mysql://"+host+"/"+dbName+"?user="+user+"&password="+pass+"&useUnicode=true&characterEncoding=UTF-8";

conn= DriverManager.getConnection(url);

return conn.createStatement();

}

/**

* 查询数据库

* @param stmt

* @param query

* @return

* @throws Exception

*/

public ResultSet executeQuery(Statement stmt,String query) throws Exception{

ResultSet rs=stmt.executeQuery(query);

return rs;

}

/**

* 更新数据库

* @param stmt

* @param query

* @throws SQLException

*/

public void executeUpdate(Statement stmt,String query) throws SQLException{

stmt.executeUpdate(query);

}

/**

* 关闭链接

* @throws SQLException

*/

public void close() throws SQLException{

if(conn!=null)

conn.close();

}

public static void main(String args[]) throws Exception {

String user="root";

String pass="root";

String host="localhost";

String dbName="sq_xfok";

DBMysql db=new DBMysql();

String query="SELECT * FROM master_posts LIMIT 1";

Statement stmt=db.getStatement(host, user, pass, dbName);

ResultSet rs=db.executeQuery(stmt, query);

while(rs.next()){

System.out.println(rs.getString(1) + "/t" + rs.getString(2) + "/t"

+ rs.getString(3) + "/t" + rs.getString(4) + "/t"

+ rs.getString(5));

}

}

}

转载请注明出处：http://www.xfok.net/2009/10/134513.html