Java链接数据库(汇)

通过springboot操作读写数据库,首先在pom.xml引入对应的依赖jar包

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.10</version>
</dependency>
<!--通用mapper-->
<dependency>
    <groupId>tk.mybatis</groupId>
    <artifactId>mapper-spring-boot-starter</artifactId>
    <version>2.1.5</version>
</dependency>
<!-- 数据库驱动 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.19</version>
</dependency>
<!-- oracle ojdbc -->
<dependency>
    <groupId>oracle</groupId>
    <artifactId>ojdbc6</artifactId>
    <version>11.2.0.3</version>
</dependency>

然后进入application.properties,写入链接数据库的地址

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://IP:3306/canace?useUnicode=true&characterEncoding=UTF-8&useSSL=false&allowMultiQueries=true
spring.datasource.username=root
spring.datasource.password=(密码)

创建数据库连接池

private static DruidDataSource dataSource;
    static {
        Properties properties = ProPertiesUtil.getProperties("application.properties");
        // 使用德鲁伊数据库连接池工厂类
        try {
            dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

获取链接对象

/**
     * 获取连接对象(从数据库连接池中获取)
     * @return 连接对象
     */
    public static Connection getConnection() {
        Connection connection = null;
        try {
            connection = dataSource.getConnection();
        } catch (Exception e) {
            return null;
        }
        return connection;
    }

通过sql语句写入mysql数据库(QueryRunner模式)

public void addUser(userAllModel use) {
        //创建QueryRunner 对象
        QueryRunner queryRunner = new QueryRunner();
        //获取Connection连接
        Connection connection = JDBCUtil.getConnection();
        //定义sql语句
        String sql = "insert into user(username,description,content) values(?,?,?)";
        try {
            int update = queryRunner.update(connection, sql, use.getUsername(), use.getDescription(), use.getContent());
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtil.close(connection);
        }
    }

查询语句,结果返回格式是Map集合

public String selectLast() {
        //创建QueryRunner 对象
        QueryRunner queryRunner = new QueryRunner();
        //获取Connection连接
        Connection connection = JDBCUtil.getConnection();
        //定义sql语句
        String sql = "select * from user order by id desc limit 1";
        try {
            //这条记录返回Map集合
            Map<String, Object> objectMap = queryRunner.query(connection, sql, new MapHandler());
            return JSON.toJSONString(objectMap);
        } catch (SQLException e) {
            e.printStackTrace();
        } 
        return null;
    }

第二、下面是DriverManager的链接方式:

static String driverClass = "oracle.jdbc.driver.OracleDriver"; //oracle的驱动
static String url = "jdbc:oracle:thin:@IP:1521:ORCL";  //连接oracle
static String user = "System";   //user是数据库的用户名
static String password = "123456";  //用户登录密码

 public static Connection getconn() {  //为了方便下面的讲解,这里专门建立了一个用于数据库连接的一个方法
        Connection conn = null;
        try {
            Class.forName(driverClass);//首先建立驱动
            conn = DriverManager.getConnection(url, user, password);  //驱动成功后进行连接
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn; //返回一个连接
    }

    public List<UserModel> selectAll() {
        List<UserModel> uselist = new ArrayList<UserModel>();
        try {
            Connection conn = getconn();
            Statement st = conn.createStatement();
            //创建sql查询语句
            String querySQL = "SELECT * FROM \"C##CCTEST\".T_USER";
            //执行sql语句并且换回一个查询的结果集
            ResultSet rs = st.executeQuery(querySQL);
            while (rs.next()) {  //循环遍历结果集
                UserModel use = new UserModel();
                int id = rs.getInt("id");
                String userid = rs.getString("userid");
                use.setID(id);
                use.setUSERID(userid);
                uselist.add(use);
            }
            st.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return uselist;
    }

第三、Mapper的方式:

1】项目的架构,resources下面建立文件夹mapper,文件夹下面建立文件UserMapper.xml。在java下方建立同名的文件夹和文件。

2】resources下面UserMapper.xml写入下面内容,mapper namespace=对应的是java下面UserMapper的绝对路径。resultMap type=对应java下面User对象的绝对路径。User对象与数据库中一致。
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.pamirs.agent.httptest.demo.mapper.UserMapper">
    <resultMap id="BaseResultMap" type="com.pamirs.agent.httptest.demo.entity.User">
        <id column="id" jdbcType="BIGINT" property="id"/>
        <result column="name" jdbcType="VARCHAR" property="name"/>
        <result column="description" jdbcType="VARCHAR" property="description"/>
    </resultMap>

    <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
        select
        <include refid="Base_Column_List"/>
        from user where id = #{id,jdbcType=BIGINT}
    </select>
</mapper>

3】java的UserMapper下面方法与resources的id名称一致。

@Component
public interface UserMapper {
    User selectByPrimaryKey(Long id);
}

4】创建方法,调用UserMapper

@Resource
private UserMapper userMapper;
@Override
public User getUserById(Long id) {
   return userMapper.selectByPrimaryKey(id);
}

5】在application.properties中添加mybatis.typeAliasesPackage和mybatis.mapperLocations,typeAliasesPackage=java下面mapper的绝对路径。

mybatis.mapperLocations=classpath*:/mapper/*.xml
mybatis.typeAliasesPackage=com.pamirs.agent.httptest.demo

6】在启动类里面添加启动项,MapperScan对应java下面mapper的绝对路径。

@SpringBootApplication
@MapperScan("com.pamirs.agent.httptest.demo.mapper")
public class HttpApplication {
    public static void main(String[] args) {
        SpringApplication.run(HttpApplication.class, new String[]{"--spring.profiles.active=c"});
    }
}
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,530评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 86,403评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,120评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,770评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,758评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,649评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,021评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,675评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,931评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,751评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,410评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,004评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,969评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,042评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,493评论 2 343

推荐阅读更多精彩内容