package mysql;
import javasql;
/
@author xys
/
public class ConnectMysql {
public static Connection getConnection() throws ClassNotFoundException, SQLException {
String url = "jdbc:mysql://localhost:3306/databaseName";
String user = "mysqluser";
String password = "password";
String driverClass = "commysqlcjjdbcDriver";
Connection connection = null;
ClassforName(driverClass);
try {
connection = DriverManagergetConnection(url, user, password);
} catch (SQLException e) {
eprintStackTrace();
}
if (connection != null) {
Systemoutprintln("数据库连接成功");
} else {
Systemoutprintln("数据库连接失败");
connectionclose();
}
return connection;
}
public void getResult() throws ClassNotFoundException, SQLException {
// 实例化 Statement 对象
Statement statement = getConnection()createStatement();
// 要执行的 Mysql 数据库 *** 作语句(增、删、改、查)
String sql = "";
// 展开结果集数据库
ResultSet resultSet = statementexecuteQuery(sql);
while (resultSetnext()) {
// 通过字段检索
int id = resultSetgetInt("id");
String name = resultSetgetString("name");
// 输出数据
Systemoutprintln("ID : " +id);
Systemoutprintln("name :" + name);
}
// 完成后需要依次关闭
resultSetclose();
statementclose();
getConnection()close();
}
}
这个首先要看你安装的数据库,需要导入到项目中相应的数据库驱动,一下以mysql为例
//增加sql
Stringsql="INSERTINTODEMO_ORDER(ORDER_ID,ORDER_NAME)VALUES(,)";
//注册驱动
ClassforName("commysqljdbcDriver");
//获取连接3306指数据库端口,demo指数据库database名,两个root分别是数据库用户名和密码
Connectioncon=("jdbc:mysql://localhost:3306/demo","root","root"");
//预编译sql语句
pst=con(sql);
需要导入mysql-connector-javajar包
1增加\x0d\String s1="insert into tableNames (id,name,password) values(myseqnextval,,);"\x0d\ClassforName(driver);\x0d\Connection conn = DriverManagergetConnection(url,dbUser,dbPwd);\x0d\PreparedStatement prepStmt = connprepareStatement(s1);\x0d\prepStmtsetString(1,name);\x0d\prepStmtsetString(2,password);\x0d\ResultSet rs=stmtexecuteUpdate();\x0d\2、删除\x0d\String s2="delete from tbNames where name=";\x0d\ClassforName(driver);\x0d\Connection conn = DriverManagergetConnection(url,dbUser,dbPwd);\x0d\PreparedStatement prepStmt = connprepareStatement(s2);\x0d\prepStmtsetString(1,name);\x0d\ResultSet rs=stmtexecuteUpdate();\x0d\3、修改\x0d\String s3=“update tbNames set name= where id=”;\x0d\ClassforName(driver);\x0d\Connection conn = DriverManagergetConnection(url,dbUser,dbPwd);\x0d\PreparedStatement prepStmt = connprepareStatement(s3);\x0d\prepStmtsetString(1,name);\x0d\prepStmtsetString(2,id);\x0d\ResultSet rs=stmtexecuteUpdate();\x0d\4、查询\x0d\String s4="select id,name,password from tbNames";\x0d\ClassforName(driver);\x0d\Connection conn = DriverManagergetConnection(url,dbUser,dbPwd);\x0d\Statement stmt=conncreateStatement();\x0d\ResultSet rs = stmtexecuteQuery(s4);\x0d\while(rsnext){\x0d\int id=rsgetInt(1);\x0d\String name = rsgetString(2);\x0d\String pwd=rsgetString(3);\x0d\Systemoutprintln(id+name+pwd); } \x0d\\x0d\以上四步必须都得关闭连接;!!!\x0d\rsclose();\x0d\stmtclose();\x0d\connclose();
import javasql;
public class DataBasePractice {
public static void main(String[] args) {
//声明Connection对象
Connection con;
//驱动程序名
String driver = "commysqljdbcDriver";
//URL指向要访问的数据库名mydata
String url = "jdbc:mysql://localhost:3306/mydata";
//MySQL配置时的用户名
String user = "root";
//MySQL配置时的密码
String password = "root";
//遍历查询结果集
try {
//加载驱动程序
ClassforName(driver);
//1getConnection()方法,连接MySQL数据库!!
con = DriverManagergetConnection(url,user,password);
if(!conisClosed())
Systemoutprintln("Succeeded connecting to the Database!");
//2创建statement类对象,用来执行SQL语句!!
Statement statement = concreateStatement();
//要执行的SQL语句
String sql = "select from student";
//3ResultSet类,用来存放获取的结果集!!
ResultSet rs = statementexecuteQuery(sql);
Systemoutprintln("-----------------");
Systemoutprintln("执行结果如下所示:");
Systemoutprintln("-----------------");
Systemoutprintln(" 学号" + "\t" + " 姓名");
Systemoutprintln("-----------------");
String name = null;
String id = null;
while(rsnext()){
//获取stuname这列数据
name = rsgetString("stuname");
//获取stuid这列数据
id = rsgetString("stuid");
//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。
//然后使用GB2312字符集解码指定的字节数组。
name = new String(namegetBytes("ISO-8859-1"),"gb2312");
//输出结果
Systemoutprintln(id + "\t" + name);
}
rsclose();
conclose();
} catch(ClassNotFoundException e) {
//数据库驱动类异常处理
Systemoutprintln("Sorry,can`t find the Driver!");
eprintStackTrace();
} catch(SQLException e) {
//数据库连接失败异常处理
eprintStackTrace();
}catch (Exception e) {
// TODO: handle exception
eprintStackTrace();
}finally{
Systemoutprintln("数据库数据成功获取!!");
}
}
}
在上面while代码段后面添加以下代码段:
String name = null;
String id = null;
while(rsnext()){
//获取stuname这列数据
name = rsgetString("stuname");
//获取stuid这列数据
id = rsgetString("stuid");
//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。
//然后使用GB2312字符集解码指定的字节数组。
name = new String(namegetBytes("ISO-8859-1"),"gb2312");
//输出结果
Systemoutprintln(id + "\t" + name);
}
PreparedStatement psql;
ResultSet res;
//预处理添加数据,其中有两个参数--“?”
psql = conprepareStatement("insert into student values(,)");
psqlsetInt(1, 8); //设置参数1,创建id为5的数据
psqlsetString(2, "xiaogang"); //设置参数2,name 为小明
psqlexecuteUpdate(); //执行更新
//预处理更新(修改)数据
psql = conprepareStatement("update student set stuname = where stuid = ");
psqlsetString(1,"xiaowang"); //设置参数1,将name改为王五
psqlsetInt(2,10); //设置参数2,将id为2的数据做修改
psqlexecuteUpdate();
//预处理删除数据
psql = conprepareStatement("delete from student where stuid = ");
psqlsetInt(1, 5);
psqlexecuteUpdate();
//查询修改数据后student表中的数据
psql = conprepareStatement("selectfrom student");
res = psqlexecuteQuery(); //执行预处理sql语句
Systemoutprintln("执行增加、修改、删除后的数据");
while(resnext()){
name = resgetString("stuname");
id = resgetString("stuid");
name = new String(namegetBytes("ISO-8859-1"),"gb2312");
Systemoutprintln(id + "\t" + name);
}
resclose();
psqlclose();
1JDBC呗,import javasql;
传统连接方式
Connection conn = getConnection();//获得连接
//注意下边应该抛出个SQLException异常
Statement stat = conncreateStatement();
statexecuteXXX("")//执行SQL语句,查询就是Query,插入,修改这种 *** 作就Update
ResultSet result; //查询后返回的结果集用这个保存
connclose//最后别忘了关闭连接
2当然是Hibernate了,是一种持久层技术,建立相应的实体后可以把数据库当对象 *** 作,非常方便,具体使用我觉得应该看看书会比较好!
先把下面我改好的,你使用一下。如果还有问题的话,你再补充。
<Resource name="jdbc/sqlserver"
auth="Container"
type="javaxsqlDataSource" />
<ResourceParams name="jdbc/sqlserver">
<parameter>
<name>factory</name>
<value>orgapachecommonsdbcpBasicDataSourceFactory</value>
</parameter>
<parameter>
<name>maxActive</name>
<value>100</value>
</parameter>
<parameter>
<name>maxIdle</name>
<value>30</value>
</parameter>
<parameter>
<name>maxWait</name>
<value>10000</value>
</parameter>
<parameter>
<name>username</name>
<value>aa</value>
</parameter>
<parameter>
<name>password</name>
<value>yht</value>
</parameter>
<parameter>
<name>driverClassName</name>
<value>commicrosoftjdbcsqlserverSQLServerDriver</value>
</parameter>
<parameter>
<name>url</name>
<value>jdbc:microsoft:sqlserver://127001:1433;database=JDemo</value>
</parameter>
</ResourceParams>
如果不行的话,那么你再做如下修改:
将<parameter>
<name>url</name>
<value>jdbc:microsoft:sqlserver://127001:1433;database=JDemo</value>
</parameter>
中的database=JDemo改为database=sqlserver
以上就是关于java连接数据库的代码全部的内容,包括:java连接数据库的代码、Java数据库连接怎么做(java代码连接数据库的步骤)、怎样编写一个java程序能通过jdbc访问数据库实现对数据库的插入、删除、修改和查询等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)