首页 / JAVA / JAVA操作mysql

JAVA操作mysql

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了JAVA操作mysql，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2696字，纯文字阅读大概需要4分钟。

内容图文

所需jar包:mysql-connector-java.jar

代码：

import java.sql.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

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

public class ConnectMySQL {

	public static String driver = "com.mysql.jdbc.Driver";

	private static String host;

	private static String user;

	private static String pwd;

	private static Connection conn = null;

	private static Statement stmt = null;

	public static void connect(String host, String user, String pwd) {
		ConnectMySQL.close();
		ConnectMySQL.host = host;
		ConnectMySQL.user = user;
		ConnectMySQL.pwd = pwd;
	}

	public static synchronized List<HashMap<String, String>> query(String sql) {
		return ConnectMySQL.result(sql);
	}

	public static synchronized void close() {
		try {
			if (stmt != null) {
				stmt.close();
				stmt = null;
			}
			if (conn != null) {
				conn.close();
				conn = null;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	private static void connectMySQL() {
		try {
			Class.forName(driver).newInstance();
			conn = (Connection) DriverManager.getConnection("jdbc:mysql://"
					+ host + "?useUnicode=true&characterEncoding=UTF8", user,
					pwd);
		} catch (InstantiationException e) {
			e.printStackTrace();
		} catch (IllegalAccessException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}

	}

	private static void statement() {
		if (conn == null) {
			ConnectMySQL.connectMySQL();
		}
		try {
			stmt = (Statement) conn.createStatement();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	private static ResultSet resultSet(String sql) {
		ResultSet rs = null;
		if (stmt == null) {
			ConnectMySQL.statement();
		}
		try {
			rs = stmt.executeQuery(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}

	private static List<HashMap<String, String>> result(String sql) {
		ResultSet rs = ConnectMySQL.resultSet(sql);
		List<HashMap<String, String>> result = new ArrayList<HashMap<String, String>>();
		try {
			ResultSetMetaData md = rs.getMetaData();
			int cc = md.getColumnCount();
			while (rs.next()) {
				HashMap<String, String> columnMap = new HashMap<String, String>();
				for (int i = 1; i <= cc; i++) {
					columnMap.put(md.getColumnName(i), rs.getString(i));
				}
				result.add(columnMap);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return result;
	}

	public static void main(String[] args) throws SQLException {
		ConnectMySQL
				.connect("192.168.1.1/test", "test", "test");
		List<HashMap<String, String>> rs = ConnectMySQL
				.query("SELECT * from test");
		System.out.println(rs.get(0).get("test"));
		ConnectMySQL.close();
	}
}

 

原文：http://www.cnblogs.com/zhangfei/p/3992041.html

内容总结

以上是互联网集市为您收集整理的JAVA操作mysql全部内容，希望文章能够帮你解决JAVA操作mysql所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1291693.html

来源：【匿名】