java程序连接MySql的主流方法是通过JDBC,你需要去MySql官网下一个他们的驱动包,然后以外部包的形式导入到项目中
建立连接
进行查询
ClassforName("commysqljdbcDriver");//DatabaseName是数据库名
Connection ct=DriverManagergetConnection("jdbc:mysql://localhost:3306/DatabaseName",username,password);
//此时就可以使用这个连接进行增删改查了
我这里贴上我以前写的一个demo的部分查询代码
PreparedStatment ps=ctprepareStatement("select from students where Number=");//sql语句结尾不需要;//可以为任何类型 在函数中声明 类似psset类型(第几个,数据);
//sql语句可以为任何种类,第一个是从1开始
pssetInt(1,2);
ResultSet rs=psexecuteQuery();
while(rsnext()){
int Number=rsgetInt(1);//第一个字段,顺序与sql语句查询的顺序对应,若为则按照表中字段顺序获取
Time Time=rsgetTime(3);
String Name=rsgetString(2);
String Sex=rsgetString(4);
Systemoutprintln("编号:"+Number+",姓名:"+Name+",出生时间:"+Time+",性别:"+Sex);
}
项目最后需要关闭连接
ctclose();连接数据库
import javasqlConnection;
import javasqlDriverManager;
import javasqlSQLException;
import javasqlStatement;
public class TestDB {
public static void main(String[] args) {
try {
// 1注册驱动
ClassforName("commicrosoftsqlserverjdbcSQLServerDriver");
Systemoutprintln("注册驱动成功");
String url = ""jdbc:microsoftsqlserver://127001:1433;DatabaseName="; //数据库IP,端口,数据库名
String username = "";
String password = "";
// 加载驱动并获取数据库连接对象
Connection connection = DriverManagergetConnection(url, username,
password);
Systemoutprintln("连接数据库成功!");
// 创建Statement对象
Statement stmt = connectioncreateStatement();
// SQL语句
String sql = "insert into student(id,name,age,email,address) values(1,'tom',23,'dfg@163com','England') ";
int rows = stmtexecuteUpdate(sql);
if (rows > 0) {
Systemoutprintln("插入成功!");
}
// 释放资源
stmtclose();
connectionclose();
} catch (SQLException e) {
eprintStackTrace();
}
catch (ClassNotFoundException e) {
eprintStackTrace();
}
}
}
预编译的数据库处理
public class ConnectionManager{
public static final String DRIVER_CLASS ="";
public static final String URL = "";
public static final String USERNAME = "";
public static final String PASSWORD = "";
//获取连接对象
public static Connection getConnection(){
Connection conn = null;
ClassforName(DRIVER_CLASS);
conn = DriverManagergetConnection(URL,USERNAME,PASSWORD);
return conn;
}
public static void closeAll(ResultSet rs,Statement stmt,Connection conn){
try{
if(rs!=null){
rsclose();
rs = null;
}
if(stmt!=null){
stmtclose();
stmt = null;
}
if(conn!=null){
connclose();
conn=null;
}
}
}
}
public class DBOperator{
public int executeUpdate(String sql,Object[] params){
int rows = 0;
Connection connn = ConnectionManagergetConnection();
PreparedStatement pstmt = connprepareStatement(sql);
if(params!=null){
for(int i=0;i<paramslength;i++){
pstmtsetObject(i+1,params[i]);//下标从1开始
}
}
rows = pstmtexecuteUpdate();
ConnectionManagercloseAll(null,pstmt,conn);
return rows;
}
public ResultSet executeQuery(String sql,Object[] params){
Connetion conn = ConnectionManagergetConnection();
if(params!=null){
for(int i= 0;i<paramslength;i++){
pstmtsetObject(i+1,params(i));
}
}
rs=pstmtexecuteQuery();
ConnectionManagercloseAll(rs,pstmt,conn);
return rs;
}
}
/
statement连接数据库
/
public class TestOperatorGrade{
private static void updateGrade(int id,String name,String description){
ClassforName();//注册驱动
Connection conn = DirverManagergetConnection("","","");
Statement stmt = conncreateStament();
String sql = "UPDATE grades set name = '"+name+"',description='"+description+"'WHere id="+id;
int rows = stmtexecuteUpdate(sql);
}
}
这是java 程序的代码
1、加载驱动程序。
2、创建连接对象。
3、创建sql语句执行对象 。
4、执行sql语句。
5、对执行结果进行处理。
6、关闭相关的连接对象即可(顺序跟声明的顺序相反)。
处理结果两种情况:
1、执行更新返回的是本次 *** 作影响到的记录数。
2、执行查询返回的结果是一个ResultSet对象。
ResultSet包含符合SQL语句中条件的所有行,并且它通过一套get方法提供了对这些 行中数据的访问。
扩展资料:
Statement
要执行SQL语句,必须获得javasqlStatement实例,Statement实例分为以下3 种类型:
1、执行静态SQL语句。通常通过Statement实例实现。
2、执行动态SQL语句。通常通过PreparedStatement实例实现。
3、执行数据库存储过程。通常通过CallableStatement实例实现。
参考资料:
进行一次数据库 *** 作,比如一个简单的查询,花费的时间可以看成:代码运行时间数据库连接时间数据库 *** 作时间(这里是查询),建立连接池能将数据库的这个连接保持在连接池中,需要进行数据库 *** 作的时候,直接调用就行,不像往常一样,重新建立连接,用完销毁。
以上就是关于说明在java程序中连接并查询Mysql的主要命令和步骤全部的内容,包括:说明在java程序中连接并查询Mysql的主要命令和步骤、java程序连接sql server2008数据库:求给一个具体的代码,和过程。、怎么使用JAVA连接数据库等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)