Examples of DbSqlSession

Examples of org.activiti.engine.impl.db.DbSqlSession

270
271
272
273
274
275
276
277
278
279
280
281
282
      ((ProcessEngineImpl)processEngine)
      .getProcessEngineConfiguration().getCommandExecutor()
        .execute(new Command<Object>() {
          public Object execute(CommandContext commandContext) {
            DbSqlSession dbSqlSession = commandContext.getSession(DbSqlSession.class);
            dbSqlSession.dbSchemaDrop();
            dbSqlSession.dbSchemaCreate();
            return null;
          }
        });
     
      throw new AssertionError(outputMessage.toString());
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

188
189
190
191
192
193
194
195
196
197
198
199
200
      log.info("dropping and recreating db");
     
      CommandExecutor commandExecutor = ((ProcessEngineImpl)processEngine).getProcessEngineConfiguration().getCommandExecutorTxRequired();
      commandExecutor.execute(new Command<Object>() {
        public Object execute(CommandContext commandContext) {
          DbSqlSession session = commandContext.getSession(DbSqlSession.class);
          session.dbSchemaDrop();
          session.dbSchemaCreate();
          return null;
        }
      });

      if (exception!=null) {
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

44
45
46
47
48
49
50
51
    getDbSqlSession().insert((PersistentObject) user);
  }
 
  public void updateUser(UserEntity updatedUser) {
    CommandContext commandContext = Context.getCommandContext();
    DbSqlSession dbSqlSession = commandContext.getDbSqlSession();
    dbSqlSession.update(updatedUser);
  }
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

83
84
85
86
87
88
89
90
91
92
93
  public String databaseSchemaUpgrade(final Connection connection, final String catalog, final String schema) {
    return commandExecutor.execute(new Command<String>(){
      public String execute(CommandContext commandContext) {
        DbSqlSessionFactory dbSqlSessionFactory = (DbSqlSessionFactory) commandContext.getSessionFactories().get(DbSqlSession.class);
        DbSqlSession dbSqlSession = new DbSqlSession(dbSqlSessionFactory, connection, catalog, schema);
        commandContext.getSessions().put(DbSqlSession.class, dbSqlSession);
        return dbSqlSession.dbSchemaUpdate();
      }
    });
  }
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

100
101
102
103
104
105
106
107
108
109
110
111
    return task;
  }

  public void insert(ExecutionEntity execution) {
    CommandContext commandContext = Context.getCommandContext();
    DbSqlSession dbSqlSession = commandContext.getDbSqlSession();
    dbSqlSession.insert(this);
   
    if(execution != null) {
      execution.addTask(this);
    }
   
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

123
124
125
126
127
128
129
130
    setCreateTime(this.getCreateTime());
    setDueDate(this.getDueDate());
    setParentTaskId(this.getParentTaskId());
   
    CommandContext commandContext = Context.getCommandContext();
    DbSqlSession dbSqlSession = commandContext.getDbSqlSession();
    dbSqlSession.update(this);
  }
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
  public GetAttachmentContentCmd(String attachmentId) {
    this.attachmentId = attachmentId;
  }

  public InputStream execute(CommandContext commandContext) {
    DbSqlSession dbSqlSession = commandContext.getDbSqlSession();
    AttachmentEntity attachment = dbSqlSession.selectById(AttachmentEntity.class, attachmentId);
   
    String contentId = attachment.getContentId();
    if (contentId==null) {
      return null;
    }
   
    ByteArrayEntity byteArray = dbSqlSession.selectById(ByteArrayEntity.class, contentId);
    byte[] bytes = byteArray.getBytes();
   
    return new ByteArrayInputStream(bytes);
  }
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
    jobHandler.execute(this, jobHandlerConfiguration, execution, commandContext);
  }
 
  public void insert() {
    DbSqlSession dbSqlSession = Context
      .getCommandContext()
      .getDbSqlSession();
   
    dbSqlSession.insert(this);
   
    // add link to execution
    if(executionId != null) {
      ExecutionEntity execution = Context.getCommandContext()
        .getExecutionManager()
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
      execution.addJob(this);
    }
  }
 
  public void delete() {
    DbSqlSession dbSqlSession = Context
      .getCommandContext()
      .getDbSqlSession();

    dbSqlSession.delete(this);

    // Also delete the job's exception byte array
    if (exceptionByteArrayId != null) {
      Context.getCommandContext().getByteArrayManager().deleteByteArrayById(exceptionByteArrayId);
    }
View Full Code Here

Examples of org.activiti.engine.impl.db.DbSqlSession

40
41
42
43
44
45
46
47
48
49
50
    // details are not updatable so we always provide the same object as the state
    return HistoricDetailEntity.class;
  }
 
  public void delete() {
    DbSqlSession dbSqlSession = Context
      .getCommandContext()
      .getDbSqlSession();

    dbSqlSession.delete(this);
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.