数据入口java代码 Java程序入口

如何将数据库连接到java程序中，详细一点的代码有么

这是连接池的：

鹤山网站制作公司哪家好，找创新互联！从网页设计、网站建设、微信开发、APP开发、响应式网站建设等网站项目制作，到程序开发，运营维护。创新互联2013年开创至今到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选创新互联。

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.sql.DataSource;

public class BaseDao {

protected Connection conn=null;

protected PreparedStatement ps=null;

protected ResultSet rs=null;

//获取连接

protected void openConnection(){

try{

//初始化连接池

Context ctx=new InitialContext();

//数据源

DataSource ds=(DataSource) ctx.lookup("java:comp/env/jdbc/news");

//获取连接

conn=ds.getConnection();

}catch(NamingException e){

e.printStackTrace();

}catch(SQLException e){

e.printStackTrace();

}

}

//关闭连接

protected void closeResource(){

try{

if(rs!=null){

rs.close();

}

if(ps!=null){

ps.close();

}

if(conn!=null){

conn.close();

}

}catch(SQLException e){

e.printStackTrace();

}

}

其他类需要使用数据库操作，继承这个类就就行了，这是最基础的。

java连接数据库的代码

用这个类吧.好的话,给我加加分.

import java.sql.*;

/**

* @功能: 一个JDBC的本地化API连接类,封装了数据操作方法,只用传一个SQL语句即可

* @作者: 李开欢

* @日期: 2007/

*/

public class ConnectionDemo {

/*

* 这里可以将常量全部放入另一个类中,以方便修改

*/

private static Connection conn;

private static Statement ps;

private static ResultSet rs;

private static final String DRIVER = "com.microsoft.jdbc.sqlserver.SQLServerDriver";

private static final String URL = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb";

private static final String USER ="sa";

private static final String PASS = "sa";

public ConnectionDemo() {

// TODO Auto-generated constructor stub

ConnectionDemo.getConnection();

}

public static Connection getConnection(){

System.out.println("连接中...");

try {

Class.forName(ConnectionDemo.DRIVER);

conn = DriverManager.getConnection(ConnectionDemo.URL, ConnectionDemo.USER, ConnectionDemo.PASS);

System.out.println("成功连接");

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return conn;

}

public static Statement getStatement(String sql){

System.out.println("执行SQL语句中...");

try {

ps = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);

if(sql.substring(0, 6).equals("select")){

rs = ps.executeQuery(sql);

System.out.println("执行完查询操作,结果已返回ResultSet集合");

}else if(sql.substring(0, 6).equals("delete")){

ps.executeUpdate(sql);

System.out.println("已执行完毕删除操作");

}else if(sql.substring(0, 6).equals("insert")){

ps.executeUpdate(sql);

System.out.println("已执行完毕增加操作");

}else{

ps.executeUpdate(sql);

System.out.println("已执行完毕更新操作");

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return ps;

}

public static ResultSet getResultSet(){

System.out.println("查询结果为:");

return rs;

}

public static void closeConnection(){

System.out.println("关闭连接中...");

try {

if (rs != null) {

rs.close();

System.out.println("已关闭ResultSet");

}

if (ps != null) {

ps.close();

System.out.println("已关闭Statement");

}

if (conn != null) {

conn.close();

System.out.println("已关闭Connection");

}

} catch (Exception e) {

// TODO: handle exception

}

}

public static void main(String[] args) {

// TODO Auto-generated method stub

ConnectionDemo.getConnection();

String sql = "delete from type where id = 1";

ConnectionDemo.getStatement(sql);

String sql2 = "insert into type values(1,'教学设备')";

ConnectionDemo.getStatement(sql2);

String sql1 = "select * from type";

ConnectionDemo.getStatement(sql1);

ResultSet rs = ConnectionDemo.getResultSet();

System.out.println("编号 "+"类 型");

try {

while(rs.next()){

System.out.print(" "+rs.getInt(1)+" ");

System.out.println(rs.getString(2));

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

ConnectionDemo.closeConnection();

}

}

怎样用java代码把数据导入到数据库中

Java可以使用JDBC对数据库进行读写。JDBC访问一般分为如下流程：

1、加载JDBC驱动程序：

在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机），

这通过java.lang.Class类的静态方法forName(String className)实现。

例如：

try{

//加载MySql的驱动类

Class.forName("com.mysql.jdbc.Driver") ;

}catch(ClassNotFoundException e){

System.out.println("找不到驱动程序类 ，加载驱动失败！");

e.printStackTrace() ;

}

成功加载后，会将Driver类的实例注册到DriverManager类中。

2、提供JDBC连接的URL

?连接URL定义了连接数据库时的协议、子协议、数据源标识。

?书写形式：协议：子协议：数据源标识

协议：在JDBC中总是以jdbc开始

子协议：是桥连接的驱动程序或是数据库管理系统名称。

数据源标识：标记找到数据库来源的地址与连接端口。

例如：（MySql的连接URL）

jdbc:mysql://localhost:3306/test?useUnicode=truecharacterEncoding=gbk ;

useUnicode=true：表示使用Unicode字符集。如果characterEncoding设置为

gb2312或GBK，本参数必须设置为true 。characterEncoding=gbk：字符编码方式。

3、创建数据库的连接

?要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象，该对象就代表一个数据库的连接。

?使用DriverManager的getConnectin(String url,String username,String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和密码来获得。

例如：

//连接MySql数据库，用户名和密码都是root

String url = "jdbc:mysql://localhost:3306/test" ;

String username = "root" ;

String password = "root" ;

try{

Connection con =

DriverManager.getConnection(url , username , password ) ;

}catch(SQLException se){

System.out.println("数据库连接失败！");

se.printStackTrace() ;

}

4、创建一个Statement

?要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3种类型：

1、执行静态SQL语句。通常通过Statement实例实现。

2、执行动态SQL语句。通常通过PreparedStatement实例实现。

3、执行数据库存储过程。通常通过CallableStatement实例实现。

具体的实现方式：

Statement stmt = con.createStatement() ;

PreparedStatement pstmt = con.prepareStatement(sql) ;

CallableStatement cstmt = con.prepareCall("{CALL demoSp(? , ?)}") ;

5、执行SQL语句

Statement接口提供了三种执行SQL语句的方法：executeQuery 、executeUpdate和execute

1、ResultSet executeQuery(String sqlString)：执行查询数据库的SQL语句，返回一个结果集（ResultSet）对象。

2、int executeUpdate(String sqlString)：用于执行INSERT、UPDATE或DELETE语句以及SQL DDL语句，如：CREATE TABLE和DROP TABLE等

3、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的语句。

具体实现的代码：

ResultSet rs = stmt.executeQuery("SELECT * FROM ...") ;

int rows = stmt.executeUpdate("INSERT INTO ...") ;

boolean flag = stmt.execute(String sql) ;

6、处理结果

两种情况：

1、执行更新返回的是本次操作影响到的记录数。

2、执行查询返回的结果是一个ResultSet对象。

ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些行中数据的访问。

使用结果集（ResultSet）对象的访问方法获取数据：

while(rs.next()){

String name = rs.getString("name") ;

String pass = rs.getString(1); // 此方法比较高效（列是从左到右编号的，并且从列1开始）

}

7、关闭JDBC对象

操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声明顺序相反：

1、关闭记录集

2、关闭声明

3、关闭连接对象

if(rs != null){ // 关闭记录集

try{

rs.close() ;

}catch(SQLException e){

e.printStackTrace() ;

}

}

if(stmt != null){ // 关闭声明

try{

stmt.close() ;

}catch(SQLException e){

e.printStackTrace() ;

}

}

if(conn != null){ // 关闭连接对象

try{

conn.close() ;

}catch(SQLException e){

e.printStackTrace() ;

}

}

JAVA嵌入数据库：用java代码实现像数据库表中插入信息，怎么写？

Java程序向数据库中插入数据，代码如下：

//首先创建数据库，(access,oracle,mysql,sqlsever)其中之一，其中access,sqlsever需要配置数据源(odbc);//然后再eclipse中创建类(ConnDb,Test，TestBean)ConnDb功能为连接数据库，查询，插入，删除，修改数据的类，Test为含有main方法的测试类，TestBean为数据表中的字段属性及set,get方法//以下是ConnDb代码：package db;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.ArrayList;public class ConnDb {public Connection startConn(Connection conn){ try { Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); conn = DriverManager.getConnection("jdbc:odbc:数据库","用户名", "密码"); } catch (Exception e) { System.out.println("连接数据库时出现错误"); } return conn; } public ArrayList executeQuery(String sql){ Connection conn = null; Statement stmt = null; ResultSet rs = null; ArrayList list = new ArrayList(); try { conn = startConn(conn); stmt = conn.createStatement(); rs = stmt.executeQuery(sql);//sql为sql语句例如"select * from 表名"，从main方法中传进来，这里用的是ArrayList 类将查询结果存储起来 while(rs.next()){ TestBean tb = new TestBean(); tb.setTid(rs.getString("tid")); tb.setTname(rs.getString("tname")); tb.setTinfo(rs.getString("tinfo")); list.add(tb); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ closeConn(rs,stmt,conn); } return list; } public void executeUpdate(String sql){ Connection conn = null; Statement stmt = null; try { conn = startConn(conn); stmt = conn.createStatement(); stmt.executeUpdate(sql); } catch (SQLException e) { System.out.println("修改，插入或者删除数据库数据时发生错误!"); }finally{ closeConn(stmt,conn); } } public void closeConn(ResultSet rs,Statement stmt,Connection conn){ try { if(rs != null){ rs.close(); } if(stmt != null){ stmt.close(); } if(conn != null){ conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("关闭数据库的时候发生错误!"); } } public void closeConn(Statement stmt,Connection conn){ try { if(stmt != null){ stmt.close(); } if(conn != null){ conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("关闭数据库的时候发生错误!"); } }}

连接数据库的代码用java怎么做?

import java.sql.*;

import javax.swing.*;

import java.awt.*;

import java.awt.event.*;

import java.util.*;

public class inensshow extends JFrame {

private Connection connection;

private Statement statement;

private ResultSet resultSet;

private ResultSetMetaData rsMetaData;

//GUI变量定义

private JTable table;

private JTextArea inputQuery;

private JButton submitQuery;

public inensshow()

{

//Form的标题

super( "输入SQL语句，按查询按钮查看结果。" );

String url = "jdbc:mysql://localhost:3306/web";

String username = "inens";

String password = "inens";

//加载驱动程序以连接数据库

try {

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

connection = DriverManager.getConnection(

url, username, password );

}

//捕获加载驱动程序异常

catch ( ClassNotFoundException cnfex ) {

System.err.println(

"装载 JDBC/ODBC 驱动程序失败。" );

cnfex.printStackTrace();

System.exit( 1 ); // terminate program

}

//捕获连接数据库异常

catch ( SQLException sqlex ) {

System.err.println( "无法连接数据库" );

sqlex.printStackTrace();

System.exit( 1 ); // terminate program

}

//如果数据库连接成功，则建立GUI

//SQL语句

String test="SELECT * FROM data";

inputQuery = new JTextArea( test, 4, 30 );

submitQuery = new JButton( "查询" );

//Button事件

submitQuery.addActionListener(

new ActionListener() {

public void actionPerformed( ActionEvent e )

{

getTable();

}

}

);

JPanel topPanel = new JPanel();

topPanel.setLayout( new BorderLayout() );

//将"输入查询"编辑框布置到 "CENTER"

topPanel.add( new JScrollPane( inputQuery), BorderLayout.CENTER );

//将"提交查询"按钮布置到 "SOUTH"

topPanel.add( submitQuery, BorderLayout.SOUTH );

table = new JTable();

Container c = getContentPane();

c.setLayout( new BorderLayout() );

//将"topPanel"编辑框布置到 "NORTH"

c.add( topPanel, BorderLayout.NORTH );

//将"table"编辑框布置到 "CENTER"

c.add( table, BorderLayout.CENTER );

getTable();

setSize( 500, 300 );

//显示Form

show();

}

private void getTable()

{

try {

//执行SQL语句

String query = inputQuery.getText();

statement = connection.createStatement();

resultSet = statement.executeQuery( query );

//在表格中显示查询结果

displayResultSet( resultSet );

}

catch ( SQLException sqlex ) {

sqlex.printStackTrace();

}

}

private void displayResultSet( ResultSet rs )

throws SQLException

{

//定位到达第一条记录

boolean moreRecords = rs.next();

//如果没有记录，则提示一条消息

if ( ! moreRecords ) {

JOptionPane.showMessageDialog( this,

"结果集中无记录" );

setTitle( "无记录显示" );

return;

}

Vector columnHeads = new Vector();

Vector rows = new Vector();

try {

//获取字段的名称

ResultSetMetaData rsmd = rs.getMetaData();

for ( int i = 1; i = rsmd.getColumnCount(); ++i )

columnHeads.addElement( rsmd.getColumnName( i ) );

//获取记录集

do {

rows.addElement( getNextRow( rs, rsmd ) );

} while ( rs.next() );

//在表格中显示查询结果

table = new JTable( rows, columnHeads );

JScrollPane scroller = new JScrollPane( table );

Container c = getContentPane();

c.remove(1);

c.add( scroller, BorderLayout.CENTER );

//刷新Table

c.validate();

}

catch ( SQLException sqlex ) {

sqlex.printStackTrace();

}

}

private Vector getNextRow( ResultSet rs,

ResultSetMetaData rsmd )

throws SQLException

{

Vector currentRow = new Vector();

for ( int i = 1; i = rsmd.getColumnCount(); ++i )

currentRow.addElement( rs.getString( i ) );

//返回一条记录

return currentRow;

}

public void shutDown()

{

try {

//断开数据库连接

connection.close();

}

catch ( SQLException sqlex ) {

System.err.println( "Unable to disconnect" );

sqlex.printStackTrace();

}

}

public static void main( String args[] )

{

final inensshow app =

new inensshow();

app.addWindowListener(

new WindowAdapter() {

public void windowClosing( WindowEvent e )

{

app.shutDown();

System.exit( 0 );

}

}

);

}

}

------------------------------------------------------------

这次在WIN98中就不好使了。因为Mysql的驱动程序没有也没能加入到CLASSPATH 当中，但是JSP却可以使用（JSP的98驱动加载详见Jsp与Mysql连接查错文章），所以这次我是在XPServer中测试的。