8:Mysql数据库的连接以及数据的增删改查……
导入Mysql包mysql-connector-java-5.1.0-bin
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.List;
public class test {
public test() {
// TODO Auto-generatedconstructor stub
}
public static Connection con;
/**
* @param args
*/
public static void main(String[] args) {
connectMysql();
// 增删改都是利用一个相同的方法,只是不同的SQL语句就可以;
// dealwithSql("insertinto testgql values(4,'gql4');");
// dealwithSql("delete from testgql where id='4'");
// dealwithSql("update testgql set name='ggqqll' whereid='2'");
selectSql("select * from testgql");
closeSql();
}
/**
* @param 连接Mysql数据库
* */
public static void connectMysql() {
String JDriver = "com.mysql.jdbc.Driver"; // MySQL提供的JDBC驱动,要保证它在CLASSPATH里可见
String conURL = "jdbc:mysql://localhost/test"; // 本地计算机上的MySQL数据库Company的URL
try {
Class.forName(JDriver);
} catch (ClassNotFoundException cnf_e) { // 如果找不到驱动类[一定要导入包mysql-connector-java-5.1.0-bin慎之慎之]
System.out.println("Driver NotFound: " + cnf_e);
}
try {
con = DriverManager.getConnection(conURL, "root", "root"); // 连接数据库 name pass
} catch (SQLException sql_e) { // 都是SQLException
System.out.println("无法连接数据库!!!!!!");
}
}
/**
* @param 关闭Mysql服务器
*/
public static void closeSql() {
try {
con.close();// 关闭到MySQL服务器的连接
} catch (SQLException e) {
e.printStackTrace();
System.out.println("关闭数据库出错!!!!!!");
}
}
/**
* @param 数据库的查询;
* @select_sql_str 查询语句代码String
* */
public static ResultSet selectSql(String select_sql_str) {
ResultSet rs = null;
Statement s = null;
try {
s = con.createStatement(); // Statement类用来提交SQL语句
rs = s.executeQuery(select_sql_str); // 提交查询,返回的表格保存在rs中
while (rs.next()) { //ResultSet指针指向下一个“行”
System.out.println(rs.getInt("id") + // 获取员工号
"\t" + rs.getString("name") // 获得name
);
}
s.close(); // 释放Statement对象
} catch (SQLException sql_e) { // 都是SQLException
System.out.println(sql_e);
}
return rs;
}
/**
* @param 数据库的增删改
* */
public static void dealwithSql(String add_sql_str) {
Statement st;
try {
st = con.createStatement();
st.executeUpdate(add_sql_str);
st.close();
} catch (SQLException e) {
// TODO Auto-generatedcatch block
e.printStackTrace();
}
}
}
联系客服